module HTTPX::Plugins::FiberConcurrency::ResolverNativeMethods

  1. lib/httpx/plugins/fiber_concurrency.rb

Public Instance methods

calculate_interests()
[show source]
    # File lib/httpx/plugins/fiber_concurrency.rb
220 def calculate_interests
221   return if @queries.empty?
222 
223   return unless @queries.values.any?(&:current_context?) || @connections.any?(&:current_context?)
224 
225   super
226 end
disconnect()
[show source]
    # File lib/httpx/plugins/fiber_concurrency.rb
228 def disconnect
229   return unless @connections.all?(&:current_context?)
230 
231   super
232 end
initial_call()
[show source]
    # File lib/httpx/plugins/fiber_concurrency.rb
214 def initial_call
215   return unless @queries.values.any?(&:current_context?) || @connections.any?(&:current_context?)
216 
217   super
218 end
on_io_error(e)
[show source]
    # File lib/httpx/plugins/fiber_concurrency.rb
234 def on_io_error(e)
235   # TODO: return super if this is not stream clsed in another thread
236 
237   log { "IO Erroring: #{e.message}, current:#{@name}, queries:#{@queries.size}" }
238   return unless @name
239 
240   super
241 end