- From: Adam Rice <notifications@github.com>
- Date: Thu, 03 Jun 2021 23:16:45 -0700
- To: whatwg/streams <streams@noreply.github.com>
- Cc: Subscribed <subscribed@noreply.github.com>
- Message-ID: <whatwg/streams/pull/1130/review/675944515@github.com>
@ricea approved this pull request.
lgtm
>
- 1. Let |readableStream| be a [=new=] {{ReadableStream}}.
- 1. [=ReadableStream/Set up=] |readableStream| given….
- </div>
+ 1. Let |startAlgorithm| be an algorithm that returns undefined.
+ 1. Let |pullAlgorithmWrapper| be an algorithm that runs these steps:
+ 1. If |pullAlgorithm| was given, run it.
+ 1. Return [=a promise resolved with=] undefined.
TODO: support returning a promise as with https://github.com/whatwg/streams/pull/1131
> + To <dfn export for="ReadableStream">enqueue bytes</dfn> into a {{ReadableStream}} |stream| given a
+ [=byte sequence=] |bytes|:
+
+ 1. Assert: |stream|.[=ReadableStream/[[controller]]=] [=implements=]
+ {{ReadableByteStreamController}}.
+ 1. Assert: |bytes|'s [=byte sequence/length=] is positive.
+ 1. Let |byobRequest| be !
+ [$ReadableByteStreamControllerGetBYOBRequest$](|stream|.[=ReadableStream/[[controller]]=]).
+ 1. If |byobRequest| is null, or
+ |byobRequest|.[=ReadableStreamBYOBRequest/[[view]]=].\[[ByteLength]] < |bytes|'s [=byte
+ sequence/length=], then:
+ 1. Let |uint8Array| be a new {{Uint8Array}} wrapping an {{ArrayBuffer}} backed by |bytes|.
+ 1. Perform ! [$ReadableByteStreamControllerEnqueue$](|stream|.[=ReadableStream/[[controller]]=],
+ |uint8Array|).
+ 1. Otherwise,
+ 1. Write |bytes| into
Do we need an assertion that it will fit?
--
You are receiving this because you are subscribed to this thread.
Reply to this email directly or view it on GitHub:
https://github.com/whatwg/streams/pull/1130#pullrequestreview-675944515
Received on Friday, 4 June 2021 06:17:57 UTC