Module: HTTPX::Plugins::FiberConcurrency::HTTP2Methods

Defined in:
lib/httpx/plugins/fiber_concurrency.rb

Instance Method Summary collapse

Instance Method Details

#initialize ⇒ Object 



132
133
134
135
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 132

def initialize(*)
  super
  @contexts = Hash.new { |hs, k| hs[k] = Set.new }
end

#interests ⇒ Object 



137
138
139
140
141
142
143
144
145
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 137

def interests
  if @connection.state == :connected && @handshake_completed && !@contexts.key?(Fiber.current)
    return :w unless @pings.empty?

    return
  end

  super
end

#send(request) ⇒ Object 



147
148
149
150
151
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 147

def send(request, *)
  add_to_context(request)

  super
end