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 @@ -5310,9 +5310,7 @@ side=] of [=transform streams=].
5310
5310
1. Return the result of [=reacting=] to |flushPromise|:
5311
5311
1. If |flushPromise| was fulfilled, then:
5312
5312
1. If |readable|.\[[state]] is "`errored`", throw |readable|.\[[storedError]] .
5313
- 1. Let |readableController| be |readable|.\[[readableStreamController]] .
5314
- 1. If ! [$ReadableStreamDefaultControllerCanCloseOrEnqueue$] (|readableController|) is true,
5315
- perform ! [$ReadableStreamDefaultControllerClose$] (|readableController|).
5313
+ 1. Perform ! [$ReadableStreamDefaultControllerClose$] (|readable|.\[[readableStreamController]] ).
5316
5314
1. If |flushPromise| was rejected with reason |r|, then:
5317
5315
1. Perform ! [$TransformStreamError$] (|stream|, |r|).
5318
5316
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