Closing the body after hijack

Author: Anton Zhuravsky

lib/async/http/protocol/http1/server.rb

@@ -50,7 +50,10 @@ def each(task: Task.current)
 							response = yield(request, self)
 							body = response&.body
 
-							return if hijacked?
+							if hijacked?
+								body&.close
+								return
+							end
 
 							task.defer_stop do
 								# If a response was generated, send it:

test/async/http/protocol/http11.rb

@@ -103,7 +103,7 @@ def around
 			end
 
 			it "works properly" do
-				expect(body).not.to receive(:close)
+				expect(body).to receive(:close)
 
 				response = client.get("/")