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

Function WritableStreamFinishInFlightClose

out/cli.cjs:12374–12390  ·  view source on GitHub ↗
(stream4)

Source from the content-addressed store, hash-verified

12372 WritableStreamDealWithRejection(stream4, error);
12373 }
12374 function WritableStreamFinishInFlightClose(stream4) {
12375 stream4._inFlightCloseRequest._resolve(void 0);
12376 stream4._inFlightCloseRequest = void 0;
12377 const state2 = stream4._state;
12378 if (state2 === "erroring") {
12379 stream4._storedError = void 0;
12380 if (stream4._pendingAbortRequest !== void 0) {
12381 stream4._pendingAbortRequest._resolve();
12382 stream4._pendingAbortRequest = void 0;
12383 }
12384 }
12385 stream4._state = "closed";
12386 const writer = stream4._writer;
12387 if (writer !== void 0) {
12388 defaultWriterClosedPromiseResolve(writer);
12389 }
12390 }
12391 function WritableStreamFinishInFlightCloseWithError(stream4, error) {
12392 stream4._inFlightCloseRequest._reject(error);
12393 stream4._inFlightCloseRequest = void 0;

Calls 1

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…