lib/async/http/protocol/http1/connection.rb in async-http-0.37.0 vs lib/async/http/protocol/http1/connection.rb in async-http-0.37.1

@@ -80,9 +80,21 @@
 						Async.logger.debug(self) {"Closing connection"}
 						
 						@stream.close
 					end
 					
+					def write_empty_body(body)
+						super(body)
+						
+						body.close if body
+					end
+					
+					def write_body_head(body)
+						super(body)
+						
+						body.close if body
+					end
+					
 					def read_chunked_body
 						Body::Chunked.new(self)
 					end
 					
 					def read_fixed_body(length)