nodejs
diff --git a/Collapse file
‎lib/internal/streams/readable.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/readable.js
+1-2Lines changed: 1 addition & 2 deletions b/Collapse file
‎lib/internal/streams/readable.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/readable.js
+1-2Lines changed: 1 addition & 2 deletions
diff --git a/Collapse file
‎test/parallel/test-stream-readable-pause-and-resume.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-readable-pause-and-resume.js
+16Lines changed: 16 additions & 0 deletions b/Collapse file
‎test/parallel/test-stream-readable-pause-and-resume.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-stream-readable-pause-and-resume.js
+16Lines changed: 16 additions & 0 deletions
@@ -830,8 +830,7 @@ function pipeOnDrain(src, dest) {
 
     if ((!state.awaitDrainWriters || state.awaitDrainWriters.size === 0) &&
       EE.listenerCount(src, 'data')) {
-      state.flowing = true;
-      flow(src);
+      src.resume();
     }
   };
 }
 
@@ -56,3 +56,19 @@ function readAndPause() {
     assert(readable.isPaused());
   });
 }
+
+{
+  const { PassThrough } = require('stream');
+
+  const source3 = new PassThrough();
+  const target3 = new PassThrough();
+
+  const chunk = Buffer.allocUnsafe(1000);
+  while (target3.write(chunk));
+
+  source3.pipe(target3);
+  target3.on('drain', common.mustCall(() => {
+    assert(!source3.isPaused());
+  }));
+  target3.on('data', () => {});
+}
Original file line number	Diff line number	Diff line change
`@@ -830,8 +830,7 @@ function pipeOnDrain(src, dest) {`
`830`	`830`
`831`	`831`	`if ((!state.awaitDrainWriters \|\| state.awaitDrainWriters.size === 0) &&`
`832`	`832`	`EE.listenerCount(src, 'data')) {`
`833`		`- state.flowing = true;`
`834`		`- flow(src);`
	`833`	`+ src.resume();`
`835`	`834`	`}`
`836`	`835`	`};`
`837`	`836`	`}`