diff --git a/lib/streat.js b/lib/streat.js
index <HASH>..<HASH> 100644
--- a/lib/streat.js
+++ b/lib/streat.js
@@ -153,6 +153,9 @@ Streat.prototype.next = function() {
 	res.on('end', function() {
 		runner.started = false;
 	});
+	res.on('aborted', function() {
+		destroyStreamRunner(runner);
+	});
 };
 
 function initStreamRunner(self, runner) {
destroy runner on aborted event