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

Function SetUpReadableByteStreamController

out/cli.cjs:11774–11798  ·  view source on GitHub ↗
(stream4, controller, startAlgorithm, pullAlgorithm, cancelAlgorithm, highWaterMark, autoAllocateChunkSize)

Source from the content-addressed store, hash-verified

11772 ReadableByteStreamControllerRespondInternal(controller, viewByteLength);
11773 }
11774 function SetUpReadableByteStreamController(stream4, controller, startAlgorithm, pullAlgorithm, cancelAlgorithm, highWaterMark, autoAllocateChunkSize) {
11775 controller._controlledReadableByteStream = stream4;
11776 controller._pullAgain = false;
11777 controller._pulling = false;
11778 controller._byobRequest = null;
11779 controller._queue = controller._queueTotalSize = void 0;
11780 ResetQueue(controller);
11781 controller._closeRequested = false;
11782 controller._started = false;
11783 controller._strategyHWM = highWaterMark;
11784 controller._pullAlgorithm = pullAlgorithm;
11785 controller._cancelAlgorithm = cancelAlgorithm;
11786 controller._autoAllocateChunkSize = autoAllocateChunkSize;
11787 controller._pendingPullIntos = new SimpleQueue();
11788 stream4._readableStreamController = controller;
11789 const startResult = startAlgorithm();
11790 uponPromise(promiseResolvedWith(startResult), () => {
11791 controller._started = true;
11792 ReadableByteStreamControllerCallPullIfNeeded(controller);
11793 return null;
11794 }, (r3) => {
11795 ReadableByteStreamControllerError(controller, r3);
11796 return null;
11797 });
11798 }
11799 function SetUpReadableByteStreamControllerFromUnderlyingSource(stream4, underlyingByteSource, highWaterMark) {
11800 const controller = Object.create(ReadableByteStreamController2.prototype);
11801 let startAlgorithm;

Calls 6

ResetQueueFunction · 0.85
startAlgorithmFunction · 0.85
uponPromiseFunction · 0.85
promiseResolvedWithFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…