summaryrefslogtreecommitdiff
path: root/lib/internal/streams/pipeline.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/internal/streams/pipeline.js')
-rw-r--r--lib/internal/streams/pipeline.js6
1 files changed, 5 insertions, 1 deletions
diff --git a/lib/internal/streams/pipeline.js b/lib/internal/streams/pipeline.js
index 798745a110..0c46460510 100644
--- a/lib/internal/streams/pipeline.js
+++ b/lib/internal/streams/pipeline.js
@@ -3,6 +3,10 @@
'use strict';
+const {
+ ArrayIsArray,
+} = primordials;
+
let eos;
const { once } = require('internal/util');
@@ -65,7 +69,7 @@ function popCallback(streams) {
function pipeline(...streams) {
const callback = popCallback(streams);
- if (Array.isArray(streams[0])) streams = streams[0];
+ if (ArrayIsArray(streams[0])) streams = streams[0];
if (streams.length < 2) {
throw new ERR_MISSING_ARGS('streams');