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

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

Instance Method Summary collapse

Instance Method Details

#calculate_interests ⇒ Object 



196
197
198
199
200
201
202
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 196

def calculate_interests
  return if @queries.empty?

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

  super
end

#disconnect ⇒ Object 



204
205
206
207
208
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 204

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

  super
end

#on_io_error(e) ⇒ Object 



210
211
212
213
214
215
216
217
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 210

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