stream: complete pipeline with stdio

lib/internal/streams/pipeline.js

@@ -265,6 +265,13 @@ function pipeline(...streams) {
     } else if (isStream(stream)) {
       if (isReadable(ret)) {
         ret.pipe(stream);
+
+        // Compat. Before node v10.12.0 stdio used to throw an error so
+        // pipe() did/does not end() stdio destinations.
+        // Now they allow it but "secretly" don't close the underlying fd.
+        if (stream === process.stdout || stream === process.stderr) {
+          ret.on('end', () => stream.end());
+        }
       } else {
         ret = makeAsyncIterable(ret);
 

test/parallel/test-stream-pipeline-process.js

@@ -0,0 +1,28 @@
+'use strict';
+
+const common = require('../common');
+const assert = require('assert');
+
+if (process.argv[2] === 'child') {
+  const { pipeline } = require('stream');
+  pipeline(
+    process.stdin,
+    process.stdout,
+    common.mustCall((err) => {
+      assert.ifError(err);
+    })
+  );
+} else {
+  const cp = require('child_process');
+  cp.exec([
+    'echo',
+    '"hello"',
+    '|',
+    `"${process.execPath}"`,
+    `"${__filename}"`,
+    'child'
+  ].join(' '), common.mustCall((err, stdout) => {
+    assert.ifError(err);
+    assert.strictEqual(stdout, 'hello\n');
+  }));
+}