Skip to content

Commit b8f166c

Browse files
fixup! optimize backpressure check
1 parent 3479d39 commit b8f166c

1 file changed

Lines changed: 6 additions & 7 deletions

File tree

lib/internal/webstreams/readablestream.js

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,6 @@ const {
127127
writableStreamAbort,
128128
writableStreamCloseQueuedOrInFlight,
129129
writableStreamDefaultWriterCloseWithErrorPropagation,
130-
writableStreamDefaultWriterGetDesiredSize,
131130
writableStreamDefaultWriterRelease,
132131
writableStreamDefaultWriterWrite,
133132
} = require('internal/webstreams/writablestream');
@@ -1564,12 +1563,12 @@ function readableStreamPipeTo(
15641563
setPromiseHandled(state.currentWrite);
15651564

15661565
// Check backpressure after each write
1567-
if (dest[kState].state === 'writable') {
1568-
const desiredSize = writableStreamDefaultWriterGetDesiredSize(writer);
1569-
if (desiredSize !== null && desiredSize <= 0) {
1570-
// Backpressure - stop batch and wait for ready
1571-
break;
1572-
}
1566+
if (dest[kState].backpressure) {
1567+
// Backpressure - stop batch and wait for ready
1568+
break;
1569+
} else if (dest[kState].state !== 'writable' || writableStreamCloseQueuedOrInFlight(dest)) {
1570+
// Closing or erroring - stop batch and wait for shutdown
1571+
break;
15731572
}
15741573
}
15751574

0 commit comments

Comments
 (0)