nodejs
diff --git a/Collapse file
‎lib/internal/streams/pipeline.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/pipeline.js
+4-1Lines changed: 4 additions & 1 deletion b/Collapse file
‎lib/internal/streams/pipeline.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/pipeline.js
+4-1Lines changed: 4 additions & 1 deletion
diff --git a/Collapse file
‎test/parallel/test-stream-pipeline.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-pipeline.js
+16Lines changed: 16 additions & 0 deletions b/Collapse file
‎test/parallel/test-stream-pipeline.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-pipeline.js
+16Lines changed: 16 additions & 0 deletions
@@ -142,7 +142,10 @@ async function pump(iterable, writable, finish) {
 function pipeline(...streams) {
   const callback = once(popCallback(streams));
 
-  if (ArrayIsArray(streams[0])) streams = streams[0];
+  // stream.pipeline(streams, callback)
+  if (ArrayIsArray(streams[0]) && streams.length === 1) {
+    streams = streams[0];
+  }
 
   if (streams.length < 2) {
     throw new ERR_MISSING_ARGS('streams');
 
@@ -1216,3 +1216,19 @@ const net = require('net');
     assert.strictEqual(res, 'helloworld');
   }));
 }
+
+{
+  pipeline([1, 2, 3], PassThrough({ objectMode: true }),
+           common.mustSucceed(() => {}));
+
+  let res = '';
+  const w = new Writable({
+    write(chunk, encoding, callback) {
+      res += chunk;
+      callback();
+    },
+  });
+  pipeline(['1', '2', '3'], w, common.mustSucceed(() => {
+    assert.strictEqual(res, '123');
+  }));
+}