nodejs
diff --git a/‎lib/internal/streams/pipeline.js‎
Lines changed: 4 additions & 1 deletion b/‎lib/internal/streams/pipeline.js‎
Lines changed: 4 additions & 1 deletion
diff --git a/‎test/parallel/test-stream-pipeline.js‎
Lines changed: 16 additions & 0 deletions b/‎test/parallel/test-stream-pipeline.js‎
Lines changed: 16 additions & 0 deletions
@@ -144,7 +144,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');
 
@@ -1285,3 +1285,19 @@ const net = require('net');
   });
   const pipelined = addAbortSignal(ac.signal, pipeline([r, w], cb));
 }
+
+{
+  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');
+  }));
+}