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

Function SetUpWritableStreamDefaultController

out/cli.cjs:12747–12774  ·  view source on GitHub ↗
(stream4, controller, startAlgorithm, writeAlgorithm, closeAlgorithm, abortAlgorithm, highWaterMark, sizeAlgorithm)

Source from the content-addressed store, hash-verified

12745 return x5 instanceof WritableStreamDefaultController2;
12746 }
12747 function SetUpWritableStreamDefaultController(stream4, controller, startAlgorithm, writeAlgorithm, closeAlgorithm, abortAlgorithm, highWaterMark, sizeAlgorithm) {
12748 controller._controlledWritableStream = stream4;
12749 stream4._writableStreamController = controller;
12750 controller._queue = void 0;
12751 controller._queueTotalSize = void 0;
12752 ResetQueue(controller);
12753 controller._abortReason = void 0;
12754 controller._abortController = createAbortController();
12755 controller._started = false;
12756 controller._strategySizeAlgorithm = sizeAlgorithm;
12757 controller._strategyHWM = highWaterMark;
12758 controller._writeAlgorithm = writeAlgorithm;
12759 controller._closeAlgorithm = closeAlgorithm;
12760 controller._abortAlgorithm = abortAlgorithm;
12761 const backpressure = WritableStreamDefaultControllerGetBackpressure(controller);
12762 WritableStreamUpdateBackpressure(stream4, backpressure);
12763 const startResult = startAlgorithm();
12764 const startPromise = promiseResolvedWith(startResult);
12765 uponPromise(startPromise, () => {
12766 controller._started = true;
12767 WritableStreamDefaultControllerAdvanceQueueIfNeeded(controller);
12768 return null;
12769 }, (r3) => {
12770 controller._started = true;
12771 WritableStreamDealWithRejection(stream4, r3);
12772 return null;
12773 });
12774 }
12775 function SetUpWritableStreamDefaultControllerFromUnderlyingSink(stream4, underlyingSink, highWaterMark, sizeAlgorithm) {
12776 const controller = Object.create(WritableStreamDefaultController2.prototype);
12777 let startAlgorithm;

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…