diff options
Diffstat (limited to 'deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js')
-rw-r--r-- | deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js b/deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js index f92fc19fef..b3a9068634 100644 --- a/deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js +++ b/deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js @@ -27,21 +27,21 @@ var eos = function(stream, opts, callback) { var onfinish = function() { writable = false; - if (!readable) callback(); + if (!readable) callback.call(stream); }; var onend = function() { readable = false; - if (!writable) callback(); + if (!writable) callback.call(stream); }; var onexit = function(exitCode) { - callback(exitCode ? new Error('exited with error code: ' + exitCode) : null); + callback.call(stream, exitCode ? new Error('exited with error code: ' + exitCode) : null); }; var onclose = function() { - if (readable && !(rs && rs.ended)) return callback(new Error('premature close')); - if (writable && !(ws && ws.ended)) return callback(new Error('premature close')); + if (readable && !(rs && rs.ended)) return callback.call(stream, new Error('premature close')); + if (writable && !(ws && ws.ended)) return callback.call(stream, new Error('premature close')); }; var onrequest = function() { @@ -80,4 +80,4 @@ var eos = function(stream, opts, callback) { }; }; -module.exports = eos;
\ No newline at end of file +module.exports = eos; |