summaryrefslogtreecommitdiff
path: root/deps/npm/node_modules/mississippi/node_modules/end-of-stream/index.js
diff options
context:
space:
mode:
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.js12
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;