Skip to content

Commit 71f2f31

Browse files
Assert that reader is a default reader in finalize
1 parent 4c8538e commit 71f2f31

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
@@ -2337,10 +2337,9 @@ The following abstract operations operate on {{ReadableStream}} instances at a h
23372337
1. [=Finalize=], passing along |error| if it was given.
23382338
* <dfn id="rs-pipeTo-finalize"><i>Finalize</i></dfn>: both forms of shutdown will eventually ask
23392339
to finalize, optionally with an error |error|, which means to perform the following steps:
2340+
1. Assert: |reader| [=implements=] {{ReadableStreamDefaultReader}}.
23402341
1. Perform ! [$WritableStreamDefaultWriterRelease$](|writer|).
2341-
1. If |reader| [=implements=] {{ReadableStreamBYOBReader}}, perform
2342-
! [$ReadableStreamBYOBReaderRelease$](|reader|).
2343-
1. Otherwise, perform ! [$ReadableStreamDefaultReaderRelease$](|reader|).
2342+
1. Perform ! [$ReadableStreamDefaultReaderRelease$](|reader|).
23442343
1. If |signal| is not undefined, [=AbortSignal/remove=] |abortAlgorithm| from |signal|.
23452344
1. If |error| was given, [=reject=] |promise| with |error|.
23462345
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
@@ -340,6 +340,7 @@ function ReadableStreamPipeTo(source, dest, preventClose, preventAbort, preventC
340340
}
341341

342342
function finalize(isError, error) {
343+
assert(ReadableStreamDefaultReader.isImpl(reader));
343344
WritableStreamDefaultWriterRelease(writer);
344345
ReadableStreamDefaultReaderRelease(reader);
345346

0 commit comments

Comments
 (0)