MCPcopy Index your code
hub / github.com/di-sukharev/opencommit / TransformStreamDefaultSinkCloseAlgorithm

Function TransformStreamDefaultSinkCloseAlgorithm

out/cli.cjs:14632–14658  ·  view source on GitHub ↗
(stream4)

Source from the content-addressed store, hash-verified

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;

Callers 1

closeAlgorithmFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…