HTTPX::Plugins::FiberConcurrency::HTTP2Methods

Methods

Public Class

new

Public Instance

interests
send

Public Class methods

new(*)

    # File lib/httpx/plugins/fiber_concurrency.rb
138 def initialize(*)
139   super
140   @contexts = Hash.new { |hs, k| hs[k] = Set.new }
141 end

Public Instance methods

interests()

    # File lib/httpx/plugins/fiber_concurrency.rb
143 def interests
144   if @connection.state == :connected && @handshake_completed && !@contexts.key?(Fiber.current)
145     return :w unless @pings.empty?
146 
147     return
148   end
149 
150   super
151 end

send(request, *)

    # File lib/httpx/plugins/fiber_concurrency.rb
153 def send(request, *)
154   add_to_context(request)
155 
156   super
157 end