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