Class: Async::HTTP::Protocol::HTTP2::Response::Stream

Inherits:
Stream
  • Object
show all
Defined in:
lib/async/http/protocol/http2/response.rb

Instance Attribute Summary collapse

Attributes inherited from Stream

#headers, #input

Instance Method Summary collapse

Methods inherited from Stream

#add_header, #add_trailer, #prepare_input, #process_data, #receive_headers, #receive_trailing_headers, #send_body, #update_local_window, #window_updated

Constructor Details

#initialize ⇒ Stream

Returns a new instance of Stream.



31
32
33
34
35
36
37
38
 
# File 'lib/async/http/protocol/http2/response.rb', line 31

def initialize(*)
	super
	
	@response = Response.new(self)
	
	@notification = Async::Notification.new
	@exception = nil
end

Instance Attribute Details

#response ⇒ Object (readonly)

Returns the value of attribute response.



40
41
42
 
# File 'lib/async/http/protocol/http2/response.rb', line 40

def response
  @response
end

Instance Method Details

#accept_push_promise_stream(promised_stream_id, headers) ⇒ Object 



50
51
52
53
54
55
56
57
58
 
# File 'lib/async/http/protocol/http2/response.rb', line 50

def accept_push_promise_stream(promised_stream_id, headers)
	stream = @connection.accept_push_promise_stream(promised_stream_id, &Stream.method(:accept))
	
	stream.response.build_request(headers)
	
	@response.promises.enqueue(stream.response)
	
	return stream
end

#close(error) ⇒ Object 



108
109
110
111
112
113
114
115
116
 
# File 'lib/async/http/protocol/http2/response.rb', line 108

def close(error)
	super
	
	@response.promises.enqueue nil
	
	@exception = error
	
	notify!
end

#notify! ⇒ Object

Notify anyone waiting on the response headers to be received (or failure).



91
92
93
94
95
96
 
# File 'lib/async/http/protocol/http2/response.rb', line 91

def notify!
	if notification = @notification
		@notification = nil
		notification.signal
	end
end

#receive_initial_headers(headers, end_stream) ⇒ Object

This should be invoked from the background reader, and notifies the task waiting for the headers that we are done.



61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
 
# File 'lib/async/http/protocol/http2/response.rb', line 61

def receive_initial_headers(headers, end_stream)
	headers.each do |key, value|
		if key == STATUS
			@response.status = Integer(value)
		elsif key == PROTOCOL
			@response.protocol = value
		elsif key == CONTENT_LENGTH
			@length = Integer(value)
		else
			add_header(key, value)
		end
	end
	
	@response.headers = @headers
	
	unless @response.valid?
		send_reset_stream(::Protocol::HTTP2::Error::PROTOCOL_ERROR)
	else
		# We only construct the input/body if data is coming.
		unless end_stream
			@response.body = prepare_input(@length)
		end
	end
	
	self.notify!
	
	return headers
end

#wait ⇒ Object

Wait for the headers to be received or for stream reset.



99
100
101
102
103
104
105
106
 
# File 'lib/async/http/protocol/http2/response.rb', line 99

def wait
	# If you call wait after the headers were already received, it should return immediately:
	@notification&.wait
	
	if @exception
		raise @exception
	end
end

#wait_for_input ⇒ Object 



42
43
44
45
46
47
48
 
# File 'lib/async/http/protocol/http2/response.rb', line 42

def wait_for_input
	# The input isn't ready until the response headers have been received:
	@response.wait
	
	# There is a possible race condition if you try to access @input - it might already be closed and nil.
	return @response.body
end