File tree Expand file tree Collapse file tree 2 files changed +2
-7
lines changed
reference-implementation/lib/abstract-ops Expand file tree Collapse file tree 2 files changed +2
-7
lines changed Original file line number Diff line number Diff line change @@ -5328,9 +5328,7 @@ side=] of [=transform streams=].
5328
5328
1. Return the result of [=reacting=] to |flushPromise|:
5329
5329
1. If |flushPromise| was fulfilled, then:
5330
5330
1. If |readable|.\[[state]] is "`errored`", throw |readable|.\[[storedError]] .
5331
- 1. Let |readableController| be |readable|.\[[readableStreamController]] .
5332
- 1. If ! [$ReadableStreamDefaultControllerCanCloseOrEnqueue$] (|readableController|) is true,
5333
- perform ! [$ReadableStreamDefaultControllerClose$] (|readableController|).
5331
+ 1. Perform ! [$ReadableStreamDefaultControllerClose$] (|readable|.\[[readableStreamController]] ).
5334
5332
1. If |flushPromise| was rejected with reason |r|, then:
5335
5333
1. Perform ! [$TransformStreamError$] (|stream|, |r|).
5336
5334
1. Throw |readable|.\[[storedError]] .
Original file line number Diff line number Diff line change @@ -244,10 +244,7 @@ function TransformStreamDefaultSinkCloseAlgorithm(stream) {
244
244
if ( readable . _state === 'errored' ) {
245
245
throw readable . _storedError ;
246
246
}
247
- const readableController = readable . _readableStreamController ;
248
- if ( ReadableStreamDefaultControllerCanCloseOrEnqueue ( readableController ) === true ) {
249
- ReadableStreamDefaultControllerClose ( readableController ) ;
250
- }
247
+ ReadableStreamDefaultControllerClose ( readable . _readableStreamController ) ;
251
248
} , r => {
252
249
TransformStreamError ( stream , r ) ;
253
250
throw readable . _storedError ;
You can’t perform that action at this time.
0 commit comments