Comparing version 2.0.4 to 2.0.5
@@ -24,3 +24,3 @@ 'use strict'; | ||
function pipe(allStreams, options, callback) { | ||
var error, finish, end, open; | ||
var error, finish, end; | ||
var readError, writeError; | ||
@@ -56,4 +56,2 @@ | ||
open = true; | ||
write.on('error', onWriteError); | ||
@@ -108,5 +106,5 @@ | ||
onEnd(); | ||
}else if (writeError && end) { | ||
} else if (writeError && end) { | ||
onEnd(); | ||
} else if (open && readError) { | ||
} else if (readError) { | ||
onEnd(); | ||
@@ -113,0 +111,0 @@ } else if (bothFinish || justEnd) { |
@@ -24,3 +24,3 @@ 'use strict'; | ||
function pipe(allStreams, options, callback) { | ||
let error, finish, end, open; | ||
let error, finish, end; | ||
let readError, writeError; | ||
@@ -56,4 +56,2 @@ | ||
open = true; | ||
write.on('error', onWriteError); | ||
@@ -108,5 +106,5 @@ | ||
onEnd(); | ||
}else if (writeError && end) { | ||
} else if (writeError && end) { | ||
onEnd(); | ||
} else if (open && readError) { | ||
} else if (readError) { | ||
onEnd(); | ||
@@ -113,0 +111,0 @@ } else if (bothFinish || justEnd) { |
{ | ||
"name": "pipe-io", | ||
"version": "2.0.4", | ||
"version": "2.0.5", | ||
"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
15235
239