stream: fix premature pipeline end

Fixes: #48406
nodejs · Jun 12, 2023 · b208392 · b208392
1 parent 8244e6c
commit b208392
Show file tree

Hide file tree

Showing 2 changed files with 1,632 additions and 1,604 deletions.
diff --git a/lib/internal/streams/pipeline.js b/lib/internal/streams/pipeline.js
@@ -38,7 +38,7 @@ const {
   isTransformStream,
   isWebStream,
   isReadableStream,
-  isReadableEnded,
+  isReadableFinished,
 } = require('internal/streams/utils');
 const { AbortController } = require('internal/abort_controller');
 
@@ -424,7 +424,7 @@ function pipe(src, dst, finish, { end }) {
       dst.end();
     }
 
-    if (isReadableEnded(src)) { // End the destination if the source has already ended.
+    if (isReadableFinished(src)) { // End the destination if the source has already ended.
       process.nextTick(endFn);
     } else {
       src.once('end', endFn);