Class: Async::HTTP::Protocol::HTTP2::Response
- Inherits:
-
Response
- Object
- Protocol::HTTP::Response
- Response
- Async::HTTP::Protocol::HTTP2::Response
show all
- Defined in:
- lib/async/http/protocol/http2/response.rb
Instance Attribute Summary
Attributes inherited from Response
#connection
Instance Method Summary
collapse
Methods inherited from Response
#hijack?, #peer, #remote_address, #remote_address=
Constructor Details
#initialize(connection, 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(connection, stream_id)
@input = nil
@length = nil
super(connection.version, nil, nil, ::Protocol::HTTP::Headers.new)
@connection = connection
@stream = Stream.new(self, connection, 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(, stream_id)
promise = Promise.new(@connection, , 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
106
107
108
109
110
111
112
113
114
115
116
|
# File 'lib/async/http/protocol/http2/response.rb', line 106
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
|
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
103
104
|
# File 'lib/async/http/protocol/http2/response.rb', line 84
def (stream, , end_stream)
.each do |key, value|
if key == STATUS
@status = Integer(value)
elsif key == REASON
@reason = value
elsif key == CONTENT_LENGTH
@length = Integer(value)
elsif key == PROTOCOL
@protocol = 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
118
119
120
121
122
123
124
|
# File 'lib/async/http/protocol/http2/response.rb', line 118
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.
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
162
163
164
165
166
167
|
# File 'lib/async/http/protocol/http2/response.rb', line 133
def send_request(request)
= [
[SCHEME, request.scheme],
[METHOD, request.method],
[PATH, request.path],
]
if authority = request.authority
<< [AUTHORITY, authority]
end
if protocol = request.protocol
<< [PROTOCOL, protocol]
end
= ::Protocol::HTTP::Headers::Merged.new(
,
request.
)
if request.body.nil?
@stream.(nil, , ::Protocol::HTTP2::END_STREAM)
else
begin
@stream.(nil, )
rescue
raise RequestFailed
end
@stream.send_body(request.body)
end
end
|
#stop_connection(error) ⇒ Object
126
127
128
129
130
|
# File 'lib/async/http/protocol/http2/response.rb', line 126
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 @notification
@notification.wait
end
if @exception
raise @exception
end
end
|