(stream4, controller, startAlgorithm, writeAlgorithm, closeAlgorithm, abortAlgorithm, highWaterMark, sizeAlgorithm)
| 12745 | return x5 instanceof WritableStreamDefaultController2; |
| 12746 | } |
| 12747 | function SetUpWritableStreamDefaultController(stream4, controller, startAlgorithm, writeAlgorithm, closeAlgorithm, abortAlgorithm, highWaterMark, sizeAlgorithm) { |
| 12748 | controller._controlledWritableStream = stream4; |
| 12749 | stream4._writableStreamController = controller; |
| 12750 | controller._queue = void 0; |
| 12751 | controller._queueTotalSize = void 0; |
| 12752 | ResetQueue(controller); |
| 12753 | controller._abortReason = void 0; |
| 12754 | controller._abortController = createAbortController(); |
| 12755 | controller._started = false; |
| 12756 | controller._strategySizeAlgorithm = sizeAlgorithm; |
| 12757 | controller._strategyHWM = highWaterMark; |
| 12758 | controller._writeAlgorithm = writeAlgorithm; |
| 12759 | controller._closeAlgorithm = closeAlgorithm; |
| 12760 | controller._abortAlgorithm = abortAlgorithm; |
| 12761 | const backpressure = WritableStreamDefaultControllerGetBackpressure(controller); |
| 12762 | WritableStreamUpdateBackpressure(stream4, backpressure); |
| 12763 | const startResult = startAlgorithm(); |
| 12764 | const startPromise = promiseResolvedWith(startResult); |
| 12765 | uponPromise(startPromise, () => { |
| 12766 | controller._started = true; |
| 12767 | WritableStreamDefaultControllerAdvanceQueueIfNeeded(controller); |
| 12768 | return null; |
| 12769 | }, (r3) => { |
| 12770 | controller._started = true; |
| 12771 | WritableStreamDealWithRejection(stream4, r3); |
| 12772 | return null; |
| 12773 | }); |
| 12774 | } |
| 12775 | function SetUpWritableStreamDefaultControllerFromUnderlyingSink(stream4, underlyingSink, highWaterMark, sizeAlgorithm) { |
| 12776 | const controller = Object.create(WritableStreamDefaultController2.prototype); |
| 12777 | let startAlgorithm; |
no test coverage detected
searching dependent graphs…