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

Function SetUpTransformStreamDefaultControllerFromTransformer

out/cli.cjs:14522–14550  ·  view source on GitHub ↗
(stream4, transformer)

Source from the content-addressed store, hash-verified

14520 controller._finishPromise_reject = void 0;
14521 }
14522 function SetUpTransformStreamDefaultControllerFromTransformer(stream4, transformer) {
14523 const controller = Object.create(TransformStreamDefaultController2.prototype);
14524 let transformAlgorithm;
14525 let flushAlgorithm;
14526 let cancelAlgorithm;
14527 if (transformer.transform !== void 0) {
14528 transformAlgorithm = (chunk) => transformer.transform(chunk, controller);
14529 } else {
14530 transformAlgorithm = (chunk) => {
14531 try {
14532 TransformStreamDefaultControllerEnqueue(controller, chunk);
14533 return promiseResolvedWith(void 0);
14534 } catch (transformResultE) {
14535 return promiseRejectedWith(transformResultE);
14536 }
14537 };
14538 }
14539 if (transformer.flush !== void 0) {
14540 flushAlgorithm = () => transformer.flush(controller);
14541 } else {
14542 flushAlgorithm = () => promiseResolvedWith(void 0);
14543 }
14544 if (transformer.cancel !== void 0) {
14545 cancelAlgorithm = (reason) => transformer.cancel(reason);
14546 } else {
14547 cancelAlgorithm = () => promiseResolvedWith(void 0);
14548 }
14549 SetUpTransformStreamDefaultController(stream4, controller, transformAlgorithm, flushAlgorithm, cancelAlgorithm);
14550 }
14551 function TransformStreamDefaultControllerClearAlgorithms(controller) {
14552 controller._transformAlgorithm = void 0;
14553 controller._flushAlgorithm = void 0;

Callers 1

constructorMethod · 0.85

Calls 8

promiseResolvedWithFunction · 0.85
promiseRejectedWithFunction · 0.85
flushMethod · 0.80
createMethod · 0.45
transformMethod · 0.45
cancelMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…