Sha256: 84395b22f3d345cd51e8fc329c67e5f0a2de3ada58f02b491e65f8d6ad32668a
Contents?: true
Size: 1.24 KB
Versions: 15
Compression:
Stored size: 1.24 KB
Contents
# frozen_string_literal: true
# Released under the MIT License.
# Copyright, 2018-2024, by Samuel Williams.
require_relative "../request"
module Async
module HTTP
module Protocol
module HTTP1
class Request < Protocol::Request
def self.read(connection)
if parts = connection.read_request
self.new(connection, *parts)
end
end
UPGRADE = "upgrade"
def initialize(connection, authority, method, path, version, headers, body)
@connection = connection
# HTTP/1 requests with an upgrade header (which can contain zero or more values) are extracted into the protocol field of the request, and we expect a response to select one of those protocols with a status code of 101 Switching Protocols.
protocol = headers.delete("upgrade")
super(nil, authority, method, path, version, headers, body, protocol, self.public_method(:write_interim_response))
end
def connection
@connection
end
def hijack?
true
end
def hijack!
@connection.hijack!
end
def write_interim_response(status, headers = nil)
@connection.write_interim_response(@version, status, headers)
end
end
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems