diff --git a/lib/stream/promises.js b/lib/stream/promises.js index 0db01a8b208d60..714c8f11427e32 100644 --- a/lib/stream/promises.js +++ b/lib/stream/promises.js @@ -1,6 +1,7 @@ 'use strict'; const { + ArrayIsArray, ArrayPrototypePop, Promise, } = primordials; @@ -23,6 +24,11 @@ function pipeline(...streams) { signal = options.signal; } + // pipeline(streams) + if (streams.length === 1 && ArrayIsArray(streams[0])) { + streams = streams[0]; + } + pl(streams, (err, value) => { if (err) { reject(err);