Method: HTTPX::Connection::HTTP2#send

Defined in:
lib/httpx/connection/http2.rb

#send(request) ⇒ Object



58
59
60
61
62
63
64
65
66
67
68
69
70
71
# File 'lib/httpx/connection/http2.rb', line 58

def send(request, **)
  if !@handshake_completed ||
     @connection.active_stream_count >= @max_concurrent_requests
    @pending << request
    return
  end
  unless (stream = @streams[request])
    stream = @connection.new_stream
    handle_stream(stream, request)
    @streams[request] = stream
  end
  handle(request, stream)
  true
end