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