We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dd496c2 commit 3479d39Copy full SHA for 3479d39
1 file changed
lib/internal/webstreams/readablestream.js
@@ -127,6 +127,7 @@ const {
127
writableStreamAbort,
128
writableStreamCloseQueuedOrInFlight,
129
writableStreamDefaultWriterCloseWithErrorPropagation,
130
+ writableStreamDefaultWriterGetDesiredSize,
131
writableStreamDefaultWriterRelease,
132
writableStreamDefaultWriterWrite,
133
} = require('internal/webstreams/writablestream');
@@ -1564,7 +1565,7 @@ function readableStreamPipeTo(
1564
1565
1566
// Check backpressure after each write
1567
if (dest[kState].state === 'writable') {
- const desiredSize = writer.desiredSize;
1568
+ const desiredSize = writableStreamDefaultWriterGetDesiredSize(writer);
1569
if (desiredSize !== null && desiredSize <= 0) {
1570
// Backpressure - stop batch and wait for ready
1571
break;
0 commit comments