Comparing version 1.1.26 to 1.1.27
@@ -34,2 +34,5 @@ (function () { | ||
isFsRead = read instanceof fs.ReadStream, | ||
isFsWrite = write instanceof fs.WriteStream, | ||
rm = function(event, stream, fn) { | ||
@@ -96,3 +99,3 @@ stream.removeListener(event, fn); | ||
onEnd(); | ||
} else if (end || finish) { | ||
} else if ((end && !isFsWrite) || (write && !isFsRead) || (write && end)) { | ||
rm('error', read, onReadError); | ||
@@ -99,0 +102,0 @@ rm('error', write, onWriteError); |
{ | ||
"name": "pipe-io", | ||
"version": "1.1.26", | ||
"version": "1.1.27", | ||
"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
10052
155