summaryrefslogtreecommitdiff
path: root/lib/internal/streams
diff options
context:
space:
mode:
authorAnna Henningsen <anna@addaleax.net>2018-12-12 14:32:26 +0100
committerRich Trott <rtrott@gmail.com>2018-12-15 06:43:38 -0800
commitc9a7088bd80dc190dfc140167998bd004911eef5 (patch)
treef56608e70d5767b515b0c9bdcfc65933631c2f06 /lib/internal/streams
parentba4466e1b18cbcf56ac357974c09e1ccf9248c02 (diff)
downloadandroid-node-v8-c9a7088bd80dc190dfc140167998bd004911eef5.tar.gz
android-node-v8-c9a7088bd80dc190dfc140167998bd004911eef5.tar.bz2
android-node-v8-c9a7088bd80dc190dfc140167998bd004911eef5.zip
stream: re-use existing `once()` implementation
PR-URL: https://github.com/nodejs/node/pull/24991 Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de> Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Anto Aravinth <anto.aravinth.cse@gmail.com> Reviewed-By: Jeremiah Senkpiel <fishrock123@rocketmail.com>
Diffstat (limited to 'lib/internal/streams')
-rw-r--r--lib/internal/streams/end-of-stream.js10
1 files changed, 1 insertions, 9 deletions
diff --git a/lib/internal/streams/end-of-stream.js b/lib/internal/streams/end-of-stream.js
index 4ad7b93337..1753996a4f 100644
--- a/lib/internal/streams/end-of-stream.js
+++ b/lib/internal/streams/end-of-stream.js
@@ -7,20 +7,12 @@ const {
ERR_INVALID_ARG_TYPE,
ERR_STREAM_PREMATURE_CLOSE
} = require('internal/errors').codes;
+const { once } = require('internal/util');
function isRequest(stream) {
return stream.setHeader && typeof stream.abort === 'function';
}
-function once(callback) {
- let called = false;
- return function(err) {
- if (called) return;
- called = true;
- callback.call(this, err);
- };
-}
-
function eos(stream, opts, callback) {
if (arguments.length === 2) {
callback = opts;