- From: Takeshi Yoshino <notifications@github.com>
- Date: Wed, 01 Jul 2015 06:27:56 -0700
- To: whatwg/streams <streams@noreply.github.com>
Received on Wednesday, 1 July 2015 13:28:23 UTC
> + controller._insideUnderlyingByteSource = false;
> +}
> +
> +function CallPullOrPullIntoLaterIfNeeded(controller) {
> + if (controller._insideUnderlyingByteSource) {
> + controller._callPullOrPullIntoLaterIfNeeded = true;
> + return;
> + }
> +
> + Promise.resolve().then(CallPullOrPullIntoRepeatedlyIfNeeded.bind(undefined, controller));
> +}
> +
> +function CallPullOrPullIntoRepeatedlyIfNeeded(controller) {
> + const stream = controller._controlledReadableByteStream;
> +
> + while (true) {
Sorry. For some reason, I had to push --force. Please comment on 6c55dbf instead of bf35ce3 if you want.
---
Reply to this email directly or view it on GitHub:
https://github.com/whatwg/streams/pull/361/files#r33677426
Received on Wednesday, 1 July 2015 13:28:23 UTC