stream.rb in async-http-0.76.0

- old
+ new

@@ -57,11 +57,11 @@
 							self.receive_initial_headers(super, frame.end_stream?)
 						end
 						
 						# TODO this might need to be in an ensure block:
 						if @input and frame.end_stream?
-							@input.close($!)
+							@input.close_write
 							@input = nil
 						end
 					rescue ::Protocol::HTTP2::HeaderError => error
 						Console.logger.debug(self, error)
 						
@@ -96,11 +96,11 @@
 							unless data.empty?
 								@input.write(data)
 							end
 							
 							if frame.end_stream?
-								@input.close
+								@input.close_write
 								@input = nil
 							end
 						end
 						
 						return data
@@ -147,10 +147,10 @@
 					# While the input stream is relatively straight forward, the output stream can trigger the second case above
 					def closed(error)
 						super
 						
 						if @input
-							@input.close(error)
+							@input.close_write(error)
 							@input = nil
 						end
 						
 						if @output
 							@output.stop(error)