also end the task on 'close' and 'finish'

Author: robrich

lib/runTask.js

@@ -67,6 +67,12 @@ module.exports = function (task, taskName, taskTimeout, done) {
 		r.once('end', function () {
 			finish(streamError, 'stream');
 		});
+		r.once('close', function () {
+			finish(streamError, 'stream');
+		});
+		r.once('finish', function () {
+			finish(streamError, 'stream');
+		});
 
 	} else if (task.length === 0) {
 		// synchronous, function took in no parameters