Comparing version 1.1.14 to 1.1.15
@@ -28,3 +28,2 @@ (function () { | ||
callback.apply(null, arguments); | ||
unsetListeners(streams, fn); | ||
}; | ||
@@ -36,2 +35,8 @@ | ||
read.on('end', function onEnd() { | ||
unsetListeners(streams, fn); | ||
read.removeListener('end', onEnd); | ||
fn(); | ||
}); | ||
read.resume(); | ||
@@ -41,4 +46,3 @@ } | ||
function setListeners(streams, options, fn) { | ||
var main, | ||
read = streams[0]; | ||
var main; | ||
@@ -55,14 +59,8 @@ streams.forEach(function(stream) { | ||
}); | ||
read.on('end', fn); | ||
} | ||
function unsetListeners(streams, fn) { | ||
var read = streams[0]; | ||
streams.forEach(function(stream) { | ||
stream.removeListener('error', fn); | ||
}); | ||
read.removeListener('end', fn); | ||
} | ||
@@ -69,0 +67,0 @@ |
{ | ||
"name": "pipe-io", | ||
"version": "1.1.14", | ||
"version": "1.1.15", | ||
"author": "coderaiser <mnemonic.enemy@gmail.com> (https://github.com/coderaiser)", | ||
@@ -5,0 +5,0 @@ "description": "Pipe streams and handle events", |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
6295