lib/async/http/protocol/http2/stream.rb in async-http-0.82.0 vs lib/async/http/protocol/http2/stream.rb in async-http-0.82.1

@@ -59,14 +59,12 @@
 							self.receive_trailing_headers(super, frame.end_stream?)
 						else
 							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)
 						
 						send_reset_stream(error.code)
@@ -101,10 +99,9 @@
 								@input.write(data)
 							end
 							
 							if frame.end_stream?
 								@input.close_write
-								@input = nil
 							end
 						end
 						
 						return data
 					rescue ::Protocol::HTTP2::ProtocolError