MCPcopy Create free account
hub / github.com/di-sukharev/opencommit / TransformStreamDefaultSinkAbortAlgorithm

Function TransformStreamDefaultSinkAbortAlgorithm

out/cli.cjs:14605–14631  ·  view source on GitHub ↗
(stream4, reason)

Source from the content-addressed store, hash-verified

14603 return TransformStreamDefaultControllerPerformTransform(controller, chunk);
14604 }
14605 function TransformStreamDefaultSinkAbortAlgorithm(stream4, reason) {
14606 const controller = stream4._transformStreamController;
14607 if (controller._finishPromise !== void 0) {
14608 return controller._finishPromise;
14609 }
14610 const readable = stream4._readable;
14611 controller._finishPromise = newPromise((resolve, reject) => {
14612 controller._finishPromise_resolve = resolve;
14613 controller._finishPromise_reject = reject;
14614 });
14615 const cancelPromise = controller._cancelAlgorithm(reason);
14616 TransformStreamDefaultControllerClearAlgorithms(controller);
14617 uponPromise(cancelPromise, () => {
14618 if (readable._state === "errored") {
14619 defaultControllerFinishPromiseReject(controller, readable._storedError);
14620 } else {
14621 ReadableStreamDefaultControllerError(readable._readableStreamController, reason);
14622 defaultControllerFinishPromiseResolve(controller);
14623 }
14624 return null;
14625 }, (r3) => {
14626 ReadableStreamDefaultControllerError(readable._readableStreamController, r3);
14627 defaultControllerFinishPromiseReject(controller, r3);
14628 return null;
14629 });
14630 return controller._finishPromise;
14631 }
14632 function TransformStreamDefaultSinkCloseAlgorithm(stream4) {
14633 const controller = stream4._transformStreamController;
14634 if (controller._finishPromise !== void 0) {

Callers 1

abortAlgorithmFunction · 0.85

Tested by

no test coverage detected