class Async::HTTP::Protocol::HTTP2::Client
def call(request)
def call(request) raise ::Protocol::HTTP2::Error, "Connection closed!" if self.closed? @count += 1 response = create_response write_request(response, request) read_response(response) return response end
def create_response
def create_response Response::Stream.create(self, self.next_stream_id).response end
def initialize(stream)
def initialize(stream) @stream = stream framer = ::Protocol::HTTP2::Framer.new(@stream) super(framer) end
def read_response(response)
def read_response(response) response.wait end
def read_response(...)
def read_response(...) Traces.trace("async.http.protocol.http2.client.read_response") do super end end
def write_request(response, request)
def write_request(response, request) response.send_request(request) end
def write_request(...)
def write_request(...) Traces.trace("async.http.protocol.http2.client.write_request") do super end end