Class: Async::HTTP::Protocol::HTTP2::Response
- Inherits:
-
Response
- Object
- Protocol::HTTP::Response
- Response
- Async::HTTP::Protocol::HTTP2::Response
- Defined in:
- lib/async/http/protocol/http2/response.rb
Overview
Typically used on the client side for writing a request and reading the incoming response.
Defined Under Namespace
Classes: Stream
Instance Attribute Summary collapse
-
#request ⇒ Object
readonly
Returns the value of attribute request.
-
#stream ⇒ Object
readonly
Returns the value of attribute stream.
Instance Method Summary collapse
- #build_request(headers) ⇒ Object
- #connection ⇒ Object
- #head? ⇒ Boolean
-
#initialize(stream) ⇒ Response
constructor
A new instance of Response.
-
#send_request(request) ⇒ Object
Send a request and read it into this response.
- #valid? ⇒ Boolean
- #wait ⇒ Object
Methods inherited from Response
#hijack?, #peer, #remote_address, #remote_address=
Constructor Details
#initialize(stream) ⇒ Response
Returns a new instance of Response.
119 120 121 122 123 124 |
# File 'lib/async/http/protocol/http2/response.rb', line 119 def initialize(stream) super(stream.connection.version, nil, nil) @stream = stream @request = nil end |
Instance Attribute Details
#request ⇒ Object (readonly)
Returns the value of attribute request.
127 128 129 |
# File 'lib/async/http/protocol/http2/response.rb', line 127 def request @request end |
#stream ⇒ Object (readonly)
Returns the value of attribute stream.
126 127 128 |
# File 'lib/async/http/protocol/http2/response.rb', line 126 def stream @stream end |
Instance Method Details
#build_request(headers) ⇒ Object
145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 |
# File 'lib/async/http/protocol/http2/response.rb', line 145 def build_request(headers) request = ::Protocol::HTTP::Request.new request.headers = ::Protocol::HTTP::Headers.new headers.each do |key, value| if key == SCHEME raise ::Protocol::HTTP2::HeaderError, "Request scheme already specified!" if request.scheme request.scheme = value elsif key == AUTHORITY raise ::Protocol::HTTP2::HeaderError, "Request authority already specified!" if request. request. = value elsif key == METHOD raise ::Protocol::HTTP2::HeaderError, "Request method already specified!" if request.method request.method = value elsif key == PATH raise ::Protocol::HTTP2::HeaderError, "Request path is empty!" if value.empty? raise ::Protocol::HTTP2::HeaderError, "Request path already specified!" if request.path request.path = value elsif key.start_with? ':' raise ::Protocol::HTTP2::HeaderError, "Invalid pseudo-header #{key}!" else request.headers[key] = value end end @request = request end |
#connection ⇒ Object
129 130 131 |
# File 'lib/async/http/protocol/http2/response.rb', line 129 def connection @stream.connection end |
#head? ⇒ Boolean
137 138 139 |
# File 'lib/async/http/protocol/http2/response.rb', line 137 def head? @request&.head? end |
#send_request(request) ⇒ Object
Send a request and read it into this response.
178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 |
# File 'lib/async/http/protocol/http2/response.rb', line 178 def send_request(request) @request = request # https://http2.github.io/http2-spec/#rfc.section.8.1.2.3 # All HTTP/2 requests MUST include exactly one valid value for the :method, :scheme, and :path pseudo-header fields, unless it is a CONNECT request (Section 8.3). An HTTP request that omits mandatory pseudo-header fields is malformed (Section 8.1.2.6). pseudo_headers = [ [SCHEME, request.scheme], [METHOD, request.method], [PATH, request.path], ] # To ensure that the HTTP/1.1 request line can be reproduced accurately, this pseudo-header field MUST be omitted when translating from an HTTP/1.1 request that has a request target in origin or asterisk form (see [RFC7230], Section 5.3). Clients that generate HTTP/2 requests directly SHOULD use the :authority pseudo-header field instead of the Host header field. if = request. pseudo_headers << [AUTHORITY, ] end if protocol = request.protocol pseudo_headers << [PROTOCOL, protocol] end headers = ::Protocol::HTTP::Headers::Merged.new( pseudo_headers, request.headers ) if request.body.nil? @stream.send_headers(nil, headers, ::Protocol::HTTP2::END_STREAM) else if length = request.body.length # This puts it at the end of the pseudo-headers: pseudo_headers << [CONTENT_LENGTH, length] end # This function informs the headers object that any subsequent headers are going to be trailer. Therefore, it must be called *before* sending the headers, to avoid any race conditions. trailer = request.headers.trailer! begin @stream.send_headers(nil, headers) rescue raise RequestFailed end @stream.send_body(request.body, trailer) end end |
#valid? ⇒ Boolean
141 142 143 |
# File 'lib/async/http/protocol/http2/response.rb', line 141 def valid? !!@status end |
#wait ⇒ Object
133 134 135 |
# File 'lib/async/http/protocol/http2/response.rb', line 133 def wait @stream.wait end |