HTTPX::Plugins::FiberConcurrency::HTTP2Methods

Methods

Public Class

new

Public Instance

interests
send

Public Class methods

new(*)

    # File lib/httpx/plugins/fiber_concurrency.rb
100 def initialize(*)
101   super
102   @contexts = Hash.new { |hs, k| hs[k] = Set.new }
103 end

Public Instance methods

interests()

    # File lib/httpx/plugins/fiber_concurrency.rb
105 def interests
106   if @connection.state == :connected && @handshake_completed && !@contexts.key?(Fiber.current)
107     return :w unless @pings.empty?
108 
109     return
110   end
111 
112   super
113 end

send(request, *)

    # File lib/httpx/plugins/fiber_concurrency.rb
115 def send(request, *)
116   add_to_context(request)
117 
118   super
119 end