MCPcopy
hub / github.com/di-sukharev/opencommit / InitializeTransformStream

Function InitializeTransformStream

out/cli.cjs:14388–14414  ·  view source on GitHub ↗
(stream4, startPromise, writableHighWaterMark, writableSizeAlgorithm, readableHighWaterMark, readableSizeAlgorithm)

Source from the content-addressed store, hash-verified

14386 });
14387 }
14388 function InitializeTransformStream(stream4, startPromise, writableHighWaterMark, writableSizeAlgorithm, readableHighWaterMark, readableSizeAlgorithm) {
14389 function startAlgorithm() {
14390 return startPromise;
14391 }
14392 function writeAlgorithm(chunk) {
14393 return TransformStreamDefaultSinkWriteAlgorithm(stream4, chunk);
14394 }
14395 function abortAlgorithm(reason) {
14396 return TransformStreamDefaultSinkAbortAlgorithm(stream4, reason);
14397 }
14398 function closeAlgorithm() {
14399 return TransformStreamDefaultSinkCloseAlgorithm(stream4);
14400 }
14401 stream4._writable = CreateWritableStream(startAlgorithm, writeAlgorithm, closeAlgorithm, abortAlgorithm, writableHighWaterMark, writableSizeAlgorithm);
14402 function pullAlgorithm() {
14403 return TransformStreamDefaultSourcePullAlgorithm(stream4);
14404 }
14405 function cancelAlgorithm(reason) {
14406 return TransformStreamDefaultSourceCancelAlgorithm(stream4, reason);
14407 }
14408 stream4._readable = CreateReadableStream(startAlgorithm, pullAlgorithm, cancelAlgorithm, readableHighWaterMark, readableSizeAlgorithm);
14409 stream4._backpressure = void 0;
14410 stream4._backpressureChangePromise = void 0;
14411 stream4._backpressureChangePromise_resolve = void 0;
14412 TransformStreamSetBackpressure(stream4, true);
14413 stream4._transformStreamController = void 0;
14414 }
14415 function IsTransformStream(x5) {
14416 if (!typeIsObject(x5)) {
14417 return false;

Callers 1

constructorMethod · 0.85

Calls 3

CreateWritableStreamFunction · 0.85
CreateReadableStreamFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…