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 response.send_request(request) response.wait return response end
def create_response
def create_response Response.new(self, self.next_stream_id) end
def initialize(stream)
def initialize(stream) @stream = stream framer = ::Protocol::HTTP2::Framer.new(@stream) super(framer) end
def stop_connection(error)
def stop_connection(error) super @streams.each do |id, stream| if stream.respond_to?(:stop_connection) stream.stop_connection(error) end end end