module HTTPX::Plugins::FiberConcurrency::ResolverNativeMethods

  1. lib/httpx/plugins/fiber_concurrency.rb

Methods

Public Instance

  1. calculate_interests
  2. disconnect
  3. on_io_error

Public Instance methods

calculate_interests()
[show source]
    # File lib/httpx/plugins/fiber_concurrency.rb
196 def calculate_interests
197   return if @queries.empty?
198 
199   return unless @queries.values.any?(&:current_context?) || @connections.any?(&:current_context?)
200 
201   super
202 end
disconnect()
[show source]
    # File lib/httpx/plugins/fiber_concurrency.rb
204 def disconnect
205   return unless @connections.all?(&:current_context?)
206 
207   super
208 end
on_io_error(e)
[show source]
    # File lib/httpx/plugins/fiber_concurrency.rb
210 def on_io_error(e)
211   # TODO: return super if this is not stream clsed in another thread
212 
213   log { "IO Erroring: #{e.message}, current:#{@name}, queries:#{@queries.size}" }
214   return unless @name
215 
216   super
217 end