(stream4, controller, startAlgorithm, pullAlgorithm, cancelAlgorithm, highWaterMark, autoAllocateChunkSize)
| 11772 | ReadableByteStreamControllerRespondInternal(controller, viewByteLength); |
| 11773 | } |
| 11774 | function SetUpReadableByteStreamController(stream4, controller, startAlgorithm, pullAlgorithm, cancelAlgorithm, highWaterMark, autoAllocateChunkSize) { |
| 11775 | controller._controlledReadableByteStream = stream4; |
| 11776 | controller._pullAgain = false; |
| 11777 | controller._pulling = false; |
| 11778 | controller._byobRequest = null; |
| 11779 | controller._queue = controller._queueTotalSize = void 0; |
| 11780 | ResetQueue(controller); |
| 11781 | controller._closeRequested = false; |
| 11782 | controller._started = false; |
| 11783 | controller._strategyHWM = highWaterMark; |
| 11784 | controller._pullAlgorithm = pullAlgorithm; |
| 11785 | controller._cancelAlgorithm = cancelAlgorithm; |
| 11786 | controller._autoAllocateChunkSize = autoAllocateChunkSize; |
| 11787 | controller._pendingPullIntos = new SimpleQueue(); |
| 11788 | stream4._readableStreamController = controller; |
| 11789 | const startResult = startAlgorithm(); |
| 11790 | uponPromise(promiseResolvedWith(startResult), () => { |
| 11791 | controller._started = true; |
| 11792 | ReadableByteStreamControllerCallPullIfNeeded(controller); |
| 11793 | return null; |
| 11794 | }, (r3) => { |
| 11795 | ReadableByteStreamControllerError(controller, r3); |
| 11796 | return null; |
| 11797 | }); |
| 11798 | } |
| 11799 | function SetUpReadableByteStreamControllerFromUnderlyingSource(stream4, underlyingByteSource, highWaterMark) { |
| 11800 | const controller = Object.create(ReadableByteStreamController2.prototype); |
| 11801 | let startAlgorithm; |
no test coverage detected
searching dependent graphs…