(stream4)
| 14630 | return controller._finishPromise; |
| 14631 | } |
| 14632 | function TransformStreamDefaultSinkCloseAlgorithm(stream4) { |
| 14633 | const controller = stream4._transformStreamController; |
| 14634 | if (controller._finishPromise !== void 0) { |
| 14635 | return controller._finishPromise; |
| 14636 | } |
| 14637 | const readable = stream4._readable; |
| 14638 | controller._finishPromise = newPromise((resolve, reject) => { |
| 14639 | controller._finishPromise_resolve = resolve; |
| 14640 | controller._finishPromise_reject = reject; |
| 14641 | }); |
| 14642 | const flushPromise = controller._flushAlgorithm(); |
| 14643 | TransformStreamDefaultControllerClearAlgorithms(controller); |
| 14644 | uponPromise(flushPromise, () => { |
| 14645 | if (readable._state === "errored") { |
| 14646 | defaultControllerFinishPromiseReject(controller, readable._storedError); |
| 14647 | } else { |
| 14648 | ReadableStreamDefaultControllerClose(readable._readableStreamController); |
| 14649 | defaultControllerFinishPromiseResolve(controller); |
| 14650 | } |
| 14651 | return null; |
| 14652 | }, (r3) => { |
| 14653 | ReadableStreamDefaultControllerError(readable._readableStreamController, r3); |
| 14654 | defaultControllerFinishPromiseReject(controller, r3); |
| 14655 | return null; |
| 14656 | }); |
| 14657 | return controller._finishPromise; |
| 14658 | } |
| 14659 | function TransformStreamDefaultSourcePullAlgorithm(stream4) { |
| 14660 | TransformStreamSetBackpressure(stream4, false); |
| 14661 | return stream4._backpressureChangePromise; |
no test coverage detected
searching dependent graphs…