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

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

Instance Method Summary collapse

Instance Method Details

#initialize ⇒ Object 



100
101
102
103
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 100

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

#interests ⇒ Object 



105
106
107
108
109
110
111
112
113
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 105

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

    return
  end

  super
end

#send(request) ⇒ Object 



115
116
117
118
119
 
# File 'lib/httpx/plugins/fiber_concurrency.rb', line 115

def send(request, *)
  add_to_context(request)

  super
end