Fixed #18

zont · Feb 12, 2014 · 4298506 · 4298506
1 parent 23de634
commit 4298506
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/index.js b/index.js
@@ -48,13 +48,13 @@ module.exports = function (options) {
 
 	function write(files, processor, callback) {
 		if (processor) {
-			var stream = processor;
-			stream.on('data', callback);
+			processor.on('data', callback);
 
 			files.forEach(function(file) {
-				stream.write(file);
+				processor.write(file);
 			});
-			stream.end();
+
+			processor.removeListener('data', callback);
 		}
 		else
 			files.forEach(callback);