lib/async/http/protocol/http2/stream.rb in async-http-0.37.9 vs lib/async/http/protocol/http2/stream.rb in async-http-0.37.10

@@ -125,9 +125,18 @@
 						
 						delegate.receive_reset_stream(self, error_code)
 						
 						return error_code
 					end
+					
+					def stop_connection(error)
+						if @body
+							@body.close(error)
+							@body = nil
+						end
+						
+						delegate.stop_connection(error)
+					end
 				end
 			end
 		end
 	end
 end