Class: Async::HTTP::Protocol::HTTP2::Response
- Defined in:
- lib/async/http/protocol/http2/response.rb
Instance Attribute Summary
Attributes inherited from Response
Attributes inherited from Response
#body, #headers, #reason, #status, #version
Instance Method Summary collapse
- #close!(state) ⇒ Object
- #create_promise_stream(headers, stream_id) ⇒ Object
-
#initialize(protocol, stream_id) ⇒ Response
constructor
A new instance of Response.
- #promises ⇒ Object
- #receive_data(stream, data, end_stream) ⇒ Object
-
#receive_headers(stream, headers, end_stream) ⇒ Object
This should be invoked from the background reader, and notifies the task waiting for the headers that we are done.
- #receive_reset_stream(stream, error_code) ⇒ Object
-
#send_request(request) ⇒ Object
Send a request and read it into this response.
- #stop_connection(error) ⇒ Object
-
#wait ⇒ Object
Wait for the headers to be received or for stream reset.
Methods inherited from Response
#hijack?, #peer, #remote_address, #remote_address=
Methods inherited from Response
[], #bad_request?, #continue?, #failure?, for_exception, #partial?, #preserve_method?, #redirection?, #server_failure?, #success?, #to_s
Methods included from Body::Reader
#body?, #close, #each, #finish, #read, #save
Constructor Details
#initialize(protocol, stream_id) ⇒ Response
Returns a new instance of Response.
28 29 30 31 32 33 34 35 36 37 38 39 40 41 |
# File 'lib/async/http/protocol/http2/response.rb', line 28 def initialize(protocol, stream_id) @input = nil @length = nil super(protocol.version, nil, nil, Headers.new, nil) @protocol = protocol @stream = Stream.new(self, protocol, stream_id) @notification = Async::Notification.new @exception = nil @promises = nil end |
Instance Method Details
#close!(state) ⇒ Object
55 56 57 |
# File 'lib/async/http/protocol/http2/response.rb', line 55 def close!(state) self.promises.enqueue(nil) end |
#create_promise_stream(headers, stream_id) ⇒ Object
47 48 49 50 51 52 53 |
# File 'lib/async/http/protocol/http2/response.rb', line 47 def create_promise_stream(headers, stream_id) promise = Promise.new(@protocol, headers, stream_id) self.promises.enqueue(promise) return promise.stream end |
#promises ⇒ Object
43 44 45 |
# File 'lib/async/http/protocol/http2/response.rb', line 43 def promises @promises ||= Async::Queue.new end |
#receive_data(stream, data, end_stream) ⇒ Object
104 105 106 107 108 109 110 111 112 113 114 |
# File 'lib/async/http/protocol/http2/response.rb', line 104 def receive_data(stream, data, end_stream) unless data.empty? @input.write(data) end if end_stream @input.close end rescue @stream.send_reset_stream(0) end |
#receive_headers(stream, headers, end_stream) ⇒ Object
This should be invoked from the background reader, and notifies the task waiting for the headers that we are done.
84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 |
# File 'lib/async/http/protocol/http2/response.rb', line 84 def receive_headers(stream, headers, end_stream) headers.each do |key, value| if key == STATUS @status = Integer(value) elsif key == REASON @reason = value elsif key == CONTENT_LENGTH @length = Integer(value) else @headers[key] = value end end unless end_stream @body = @input = Body::Writable.new(@length) end notify! end |
#receive_reset_stream(stream, error_code) ⇒ Object
116 117 118 119 120 121 122 |
# File 'lib/async/http/protocol/http2/response.rb', line 116 def receive_reset_stream(stream, error_code) if error_code > 0 @exception = EOFError.new("Stream reset: error_code=#{error_code}") end notify! end |
#send_request(request) ⇒ Object
Send a request and read it into this response.
131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 |
# File 'lib/async/http/protocol/http2/response.rb', line 131 def send_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 headers = Headers::Merged.new( pseudo_headers, request.headers ) if request.body.nil? @stream.send_headers(nil, headers, ::Protocol::HTTP2::END_STREAM) else begin @stream.send_headers(nil, headers) rescue raise RequestFailed end @stream.send_body(request.body) end end |
#stop_connection(error) ⇒ Object
124 125 126 127 128 |
# File 'lib/async/http/protocol/http2/response.rb', line 124 def stop_connection(error) @exception = error notify! end |
#wait ⇒ Object
Wait for the headers to be received or for stream reset.
72 73 74 75 76 77 78 79 80 81 |
# File 'lib/async/http/protocol/http2/response.rb', line 72 def wait # If you call wait after the headers were already received, it should return immediately. if @notification @notification.wait end if @exception raise @exception end end |