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