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

Function TransformStreamDefaultSinkWriteAlgorithm

out/cli.cjs:14590–14604  ·  view source on GitHub ↗
(stream4, chunk)

Source from the content-addressed store, hash-verified

14588 TransformStreamErrorWritableAndUnblockWrite(stream4, error);
14589 }
14590 function TransformStreamDefaultSinkWriteAlgorithm(stream4, chunk) {
14591 const controller = stream4._transformStreamController;
14592 if (stream4._backpressure) {
14593 const backpressureChangePromise = stream4._backpressureChangePromise;
14594 return transformPromiseWith(backpressureChangePromise, () => {
14595 const writable = stream4._writable;
14596 const state2 = writable._state;
14597 if (state2 === "erroring") {
14598 throw writable._storedError;
14599 }
14600 return TransformStreamDefaultControllerPerformTransform(controller, chunk);
14601 });
14602 }
14603 return TransformStreamDefaultControllerPerformTransform(controller, chunk);
14604 }
14605 function TransformStreamDefaultSinkAbortAlgorithm(stream4, reason) {
14606 const controller = stream4._transformStreamController;
14607 if (controller._finishPromise !== void 0) {

Callers 1

writeAlgorithmFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…