Skip to content

Commit dd496c2

Browse files
stream: optimize webstreams pipeTo
1 parent 199daab commit dd496c2

1 file changed

Lines changed: 1 addition & 4 deletions

File tree

lib/internal/webstreams/readablestream.js

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1573,10 +1573,7 @@ function readableStreamPipeTo(
15731573
}
15741574

15751575
// Trigger pull if needed after batch
1576-
if (source[kState].state === 'readable' &&
1577-
!controller[kState].closeRequested) {
1578-
readableStreamDefaultControllerCallPullIfNeeded(controller);
1579-
}
1576+
readableStreamDefaultControllerCallPullIfNeeded(controller);
15801577

15811578
// Check if stream closed during batch
15821579
if (source[kState].state === 'closed') {

0 commit comments

Comments
 (0)