Atomic close write.

Author: ioquatix

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

@@ -62,9 +62,9 @@ def process_headers(frame)
 						end
 
 						# TODO this might need to be in an ensure block:
-						if @input and frame.end_stream?
-							@input.close_write
+						if input = @input and frame.end_stream?
 							@input = nil
+							input.close_write
 						end
 					rescue ::Protocol::HTTP2::HeaderError => error
 						Console.logger.debug(self, error)