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

Function WritableStreamDefaultControllerWrite

out/cli.cjs:12824–12837  ·  view source on GitHub ↗
(controller, chunk, chunkSize)

Source from the content-addressed store, hash-verified

12822 return controller._strategyHWM - controller._queueTotalSize;
12823 }
12824 function WritableStreamDefaultControllerWrite(controller, chunk, chunkSize) {
12825 try {
12826 EnqueueValueWithSize(controller, chunk, chunkSize);
12827 } catch (enqueueE) {
12828 WritableStreamDefaultControllerErrorIfNeeded(controller, enqueueE);
12829 return;
12830 }
12831 const stream4 = controller._controlledWritableStream;
12832 if (!WritableStreamCloseQueuedOrInFlight(stream4) && stream4._state === "writable") {
12833 const backpressure = WritableStreamDefaultControllerGetBackpressure(controller);
12834 WritableStreamUpdateBackpressure(stream4, backpressure);
12835 }
12836 WritableStreamDefaultControllerAdvanceQueueIfNeeded(controller);
12837 }
12838 function WritableStreamDefaultControllerAdvanceQueueIfNeeded(controller) {
12839 const stream4 = controller._controlledWritableStream;
12840 if (!controller._started) {

Callers 1

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…