HTTPX::Plugins::FiberConcurrency::HTTP2Methods

Methods

Public Class

new

Public Instance

interests
send

Public Class methods

new(*)

    # File lib/httpx/plugins/fiber_concurrency.rb
144 def initialize(*)
145   super
146   @contexts = Hash.new { |hs, k| hs[k] = Set.new }
147 end

Public Instance methods

interests()

    # File lib/httpx/plugins/fiber_concurrency.rb
149 def interests
150   if @connection.state == :connected && @handshake_completed && !@contexts.key?(Fiber.current)
151     return :w unless @pings.empty?
152 
153     return
154   end
155 
156   super
157 end

send(request, *)

    # File lib/httpx/plugins/fiber_concurrency.rb
159 def send(request, *)
160   add_to_context(request)
161 
162   super
163 end