fixup

Author: ronag

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;