Skip to content

Commit ab3319b

Browse files
Reset flag before processing a new chunk
1 parent 3dd3a21 commit ab3319b

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
@@ -5164,6 +5164,7 @@ The following abstract operations support the implementation of the
51645164

51655165
1. Let |stream| be |controller|.[=WritableStreamDefaultController/[[stream]]=].
51665166
1. Perform ! [$WritableStreamMarkFirstWriteRequestInFlight$](|stream|).
5167+
1. Set |controller|.[=WritableStreamDefaultController/[[releaseBackpressure]]=] to false.
51675168
1. Let |sinkWritePromise| be the result of performing
51685169
|controller|.[=WritableStreamDefaultController/[[writeAlgorithm]]=], passing in |chunk|.
51695170
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)