Public Class methods
new(*)
[show source]
# File lib/httpx/plugins/fiber_concurrency.rb 99 def initialize(*) 100 super 101 @contexts = Hash.new { |hs, k| hs[k] = Set.new } 102 end
Public Instance methods
interests()
[show source]
# File lib/httpx/plugins/fiber_concurrency.rb 104 def interests 105 if @connection.state == :connected && @handshake_completed && !@contexts.key?(Fiber.current) 106 return :w unless @pings.empty? 107 108 return 109 end 110 111 super 112 end
send(request, *)
[show source]
# File lib/httpx/plugins/fiber_concurrency.rb 114 def send(request, *) 115 add_to_context(request) 116 117 super 118 end