fixup

nodejs · Nov 8, 2021 · 4d68da2 · 4d68da2
1 parent 0e0d5c9
commit 4d68da2
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/internal/streams/pipeline.js b/lib/internal/streams/pipeline.js
@@ -348,7 +348,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;