Skip to content

Commit f6d8b73

Browse files
Assert that reader is a default reader in finalize
1 parent 124582a commit f6d8b73

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

index.bs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2233,10 +2233,9 @@ The following abstract operations operate on {{ReadableStream}} instances at a h
22332233
1. [=Finalize=], passing along |error| if it was given.
22342234
* <dfn id="rs-pipeTo-finalize"><i>Finalize</i></dfn>: both forms of shutdown will eventually ask
22352235
to finalize, optionally with an error |error|, which means to perform the following steps:
2236+
1. Assert: |reader| [=implements=] {{ReadableStreamDefaultReader}}.
22362237
1. Perform ! [$WritableStreamDefaultWriterRelease$](|writer|).
2237-
1. If |reader| [=implements=] {{ReadableStreamBYOBReader}}, perform
2238-
! [$ReadableStreamBYOBReaderRelease$](|reader|).
2239-
1. Otherwise, perform ! [$ReadableStreamDefaultReaderRelease$](|reader|).
2238+
1. Perform ! [$ReadableStreamDefaultReaderRelease$](|reader|).
22402239
1. If |signal| is not undefined, [=AbortSignal/remove=] |abortAlgorithm| from |signal|.
22412240
1. If |error| was given, [=reject=] |promise| with |error|.
22422241
1. Otherwise, [=resolve=] |promise| with undefined.

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -339,6 +339,7 @@ function ReadableStreamPipeTo(source, dest, preventClose, preventAbort, preventC
339339
}
340340

341341
function finalize(isError, error) {
342+
assert(ReadableStreamDefaultReader.isImpl(reader));
342343
WritableStreamDefaultWriterRelease(writer);
343344
ReadableStreamDefaultReaderRelease(reader);
344345

0 commit comments

Comments
 (0)