- From: Takeshi Yoshino <notifications@github.com>
- Date: Wed, 01 Jul 2015 00:41:14 -0700
- To: whatwg/streams <streams@noreply.github.com>
Received on Wednesday, 1 July 2015 07:41:42 UTC
> + const stream = controller._controlledReadableByteStream;
> + if (stream._state === 'readable') {
> + ErrorReadableByteStream(stream, e);
> + }
> + }
> +
> + controller._insideUnderlyingByteSource = false;
> +}
> +
> +function CallPullOrPullIntoLaterIfNeeded(controller) {
> + if (controller._insideUnderlyingByteSource) {
> + controller._callPullOrPullIntoLaterIfNeeded = true;
> + return;
> + }
> +
> + Promise.resolve().then(CallPullOrPullIntoRepeatedlyIfNeeded.bind(undefined, controller));
Done 24d5faf412bbf208b9f5b27b902d6f427f00ed83
---
Reply to this email directly or view it on GitHub:
https://github.com/whatwg/streams/pull/361/files#r33655088
Received on Wednesday, 1 July 2015 07:41:42 UTC