stream: support array of streams in promises pipeline

Fixes: nodejs#40191
Mesteery · Sep 23, 2021 · c9ed79f · c9ed79f
1 parent fd86dad
commit c9ed79f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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);