aboutsummaryrefslogtreecommitdiff
path: root/node_modules/end-of-stream
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2016-11-26 17:04:35 +0100
committerFlorian Dold <florian.dold@gmail.com>2016-11-26 17:04:55 +0100
commita851c3fb33335fb42de8280c6bad2a6699bb746f (patch)
treebbaea1b873ccdcbb453fdbb783fdc594da124909 /node_modules/end-of-stream
parent5c17f4b61e8caaa365339c4916222a5892b2ec3a (diff)
downloadwallet-core-a851c3fb33335fb42de8280c6bad2a6699bb746f.tar.xz
update node_modules
Diffstat (limited to 'node_modules/end-of-stream')
-rw-r--r--node_modules/end-of-stream/index.js13
-rw-r--r--node_modules/end-of-stream/package.json2
-rw-r--r--node_modules/end-of-stream/test.js9
3 files changed, 19 insertions, 5 deletions
diff --git a/node_modules/end-of-stream/index.js b/node_modules/end-of-stream/index.js
index b9fbec071..9f61ed5af 100644
--- a/node_modules/end-of-stream/index.js
+++ b/node_modules/end-of-stream/index.js
@@ -55,7 +55,18 @@ var eos = function(stream, opts, callback) {
if (opts.error !== false) stream.on('error', callback);
stream.on('close', onclose);
- return stream;
+ return function() {
+ stream.removeListener('complete', onfinish);
+ stream.removeListener('abort', onclose);
+ stream.removeListener('request', onrequest);
+ if (stream.req) stream.req.removeListener('finish', onfinish);
+ stream.removeListener('end', onlegacyfinish);
+ stream.removeListener('close', onlegacyfinish);
+ stream.removeListener('finish', onfinish);
+ stream.removeListener('end', onend);
+ stream.removeListener('error', callback);
+ stream.removeListener('close', onclose);
+ };
};
module.exports = eos; \ No newline at end of file
diff --git a/node_modules/end-of-stream/package.json b/node_modules/end-of-stream/package.json
index 1f64886ac..5e36241b5 100644
--- a/node_modules/end-of-stream/package.json
+++ b/node_modules/end-of-stream/package.json
@@ -1,6 +1,6 @@
{
"name": "end-of-stream",
- "version": "0.1.5",
+ "version": "1.0.0",
"description": "Call a callback when a readable/writable/duplex stream has completed or failed.",
"repository": {
"type": "git",
diff --git a/node_modules/end-of-stream/test.js b/node_modules/end-of-stream/test.js
index 277f1ce61..d4d126fe5 100644
--- a/node_modules/end-of-stream/test.js
+++ b/node_modules/end-of-stream/test.js
@@ -29,6 +29,12 @@ eos(rs, function(err) {
});
rs.pipe(fs.createWriteStream('/dev/null'));
+var rs = fs.createReadStream(__filename);
+eos(rs, function(err) {
+ throw new Error('no go')
+})();
+rs.pipe(fs.createWriteStream('/dev/null'));
+
var socket = net.connect(50000);
eos(socket, function(err) {
expected--;
@@ -36,7 +42,6 @@ eos(socket, function(err) {
if (!expected) process.exit(0);
});
-
var server = net.createServer(function(socket) {
eos(socket, function() {
expected--;
@@ -51,8 +56,6 @@ var server = net.createServer(function(socket) {
});
});
-
-
setTimeout(function() {
assert(expected === 0);
process.exit(0);