fixup

nodejs · Nov 8, 2021 · 3d0d042 · 3d0d042
1 parent 0e0d5c9
commit 3d0d042
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/lib/internal/streams/pipeline.js b/lib/internal/streams/pipeline.js
@@ -338,8 +338,6 @@ function pipe (src, dst) {
     dst.end();
   }
 
-  const state = src._readableState;
-
   const objectMode = (
     src.readableObjectMode ||
     src._readableState?.objectMode ||
@@ -348,7 +346,11 @@ function pipe (src, dst) {
   );
 
   function pump () {
-    while (!dst.writableNeedDrain) {
+    if (dst.writableNeedDrain) {
+      return;
+    }
+
+    while (true) {
       const chunk = src.read((!objectMode && dst.writableHighwaterMark) || undefined);
       if (chunk === null || !dst.write(chunk)) {
         return;