fixup

Author: ronag

lib/internal/streams/pipeline.js

@@ -231,9 +231,9 @@ function pipelineImpl(streams, callback, opts) {
     const writing = i > 0;
     const end = reading || opts?.end !== false;
 
-    if (isNodeStream(stream)) {
+    if (isNodeStream(stream) && end) {
       finishCount++;
-      destroys.push(destroyer(stream, reading, end && writing, (err) => {
+      destroys.push(destroyer(stream, reading, writing, (err) => {
         if (!err && !reading && isReadableFinished(stream, false)) {
           stream.read(0);
           destroyer(stream, true, writing, finish);