Module: HTTPX::Plugins::FiberConcurrency::ResolverNativeMethods

Defined in:
lib/httpx/plugins/fiber_concurrency.rb

Instance Method Summary collapse

Instance Method Details

#calculate_interests ⇒ Object 



208
209
210
211
212
213
214
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 208

def calculate_interests
  return if @queries.empty?

  return unless @queries.values.any?(&:current_context?) || @connections.any?(&:current_context?)

  super
end

#disconnect ⇒ Object 



216
217
218
219
220
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 216

def disconnect
  return unless @connections.all?(&:current_context?)

  super
end

#initial_call ⇒ Object 



202
203
204
205
206
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 202

def initial_call
  return unless @queries.values.any?(&:current_context?) || @connections.any?(&:current_context?)

  super
end

#on_io_error(e) ⇒ Object 



222
223
224
225
226
227
228
229
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 222

def on_io_error(e)
  # TODO: return super if this is not stream clsed in another thread

  log { "IO Erroring: #{e.message}, current:#{@name}, queries:#{@queries.size}" }
  return unless @name

  super
end