Skip to content

Commit 95323e7

Browse files
Reset flag before processing a new chunk
1 parent fc0cb9d commit 95323e7

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

index.bs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5295,6 +5295,7 @@ The following abstract operations support the implementation of the
52955295

52965296
1. Let |stream| be |controller|.[=WritableStreamDefaultController/[[stream]]=].
52975297
1. Perform ! [$WritableStreamMarkFirstWriteRequestInFlight$](|stream|).
5298+
1. Set |controller|.[=WritableStreamDefaultController/[[releaseBackpressure]]=] to false.
52985299
1. Let |sinkWritePromise| be the result of performing
52995300
|controller|.[=WritableStreamDefaultController/[[writeAlgorithm]]=], passing in |chunk|.
53005301
1. [=Upon fulfillment=] of |sinkWritePromise|,

reference-implementation/lib/abstract-ops/writable-streams.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -704,6 +704,7 @@ function WritableStreamDefaultControllerProcessWrite(controller, chunk) {
704704
const stream = controller._stream;
705705

706706
WritableStreamMarkFirstWriteRequestInFlight(stream);
707+
controller._releaseBackpressure = false;
707708

708709
const sinkWritePromise = controller._writeAlgorithm(chunk);
709710
uponPromise(

0 commit comments

Comments
 (0)