Method: HTTPX::Connection::HTTP2#send

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

#send(request) ⇒ Object



42
43
44
45
46
47
48
49
50
51
52
53
54
55
# File 'lib/httpx/connection/http2.rb', line 42

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