Don't set @input to nil until the stream is closed.

`wait_for_input` may race on a end frame.

Author: ioquatix

lib/async/http/protocol/http2/stream.rb

@@ -61,10 +61,8 @@ def process_headers(frame)
 							self.receive_initial_headers(super, frame.end_stream?)
 						end
 
-						# TODO this might need to be in an ensure block:
-						if input = @input and frame.end_stream?
-							@input = nil
-							input.close_write
+						if @input and frame.end_stream?
+							@input.close_write
 						end
 					rescue ::Protocol::HTTP2::HeaderError => error
 						Console.logger.debug(self, error)
@@ -103,7 +101,6 @@ def process_data(frame)
 
 							if frame.end_stream?
 								@input.close_write
-								@input = nil
 							end
 						end