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
208 def calculate_interests
209   return if @queries.empty?
210 
211   return unless @queries.values.any?(&:current_context?) || @connections.any?(&:current_context?)
212 
213   super
214 end
disconnect()
[show source]
    # File lib/httpx/plugins/fiber_concurrency.rb
216 def disconnect
217   return unless @connections.all?(&:current_context?)
218 
219   super
220 end
initial_call()
[show source]
    # File lib/httpx/plugins/fiber_concurrency.rb
202 def initial_call
203   return unless @queries.values.any?(&:current_context?) || @connections.any?(&:current_context?)
204 
205   super
206 end
on_io_error(e)
[show source]
    # File lib/httpx/plugins/fiber_concurrency.rb
222 def on_io_error(e)
223   # TODO: return super if this is not stream clsed in another thread
224 
225   log { "IO Erroring: #{e.message}, current:#{@name}, queries:#{@queries.size}" }
226   return unless @name
227 
228   super
229 end