lib/async/http/protocol/http1/server.rb in async-http-0.59.1 vs lib/async/http/protocol/http1/server.rb in async-http-0.59.2

@@ -59,10 +59,15 @@
 						task.annotate("Reading #{self.version} requests for #{self.class}.")
 						
 						while request = next_request
 							response = yield(request, self)
 							body = response&.body
-
+							
+							if @stream.nil? and body.nil?
+								# Full hijack.
+								return
+							end
+							
 							begin
 								# If a response was generated, send it:
 								if response
 									trailer = response.headers.trailer!