Skip to content

Commit eaf8f67

Browse files
Reset flag before processing a new chunk
1 parent b2b6c88 commit eaf8f67

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

index.bs

+1
Original file line numberDiff line numberDiff line change
@@ -5161,6 +5161,7 @@ The following abstract operations support the implementation of the
51615161

51625162
1. Let |stream| be |controller|.[=WritableStreamDefaultController/[[stream]]=].
51635163
1. Perform ! [$WritableStreamMarkFirstWriteRequestInFlight$](|stream|).
5164+
1. Set |controller|.[=WritableStreamDefaultController/[[releaseBackpressure]]=] to false.
51645165
1. Let |sinkWritePromise| be the result of performing
51655166
|controller|.[=WritableStreamDefaultController/[[writeAlgorithm]]=], passing in |chunk|.
51665167
1. [=Upon fulfillment=] of |sinkWritePromise|,

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

+1
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)