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

Function WritableStreamDefaultControllerProcessClose

out/cli.cjs:12866–12879  ·  view source on GitHub ↗
(controller)

Source from the content-addressed store, hash-verified

12864 }
12865 }
12866 function WritableStreamDefaultControllerProcessClose(controller) {
12867 const stream4 = controller._controlledWritableStream;
12868 WritableStreamMarkCloseRequestInFlight(stream4);
12869 DequeueValue(controller);
12870 const sinkClosePromise = controller._closeAlgorithm();
12871 WritableStreamDefaultControllerClearAlgorithms(controller);
12872 uponPromise(sinkClosePromise, () => {
12873 WritableStreamFinishInFlightClose(stream4);
12874 return null;
12875 }, (reason) => {
12876 WritableStreamFinishInFlightCloseWithError(stream4, reason);
12877 return null;
12878 });
12879 }
12880 function WritableStreamDefaultControllerProcessWrite(controller, chunk) {
12881 const stream4 = controller._controlledWritableStream;
12882 WritableStreamMarkFirstWriteRequestInFlight(stream4);

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…