MCPcopy Index your code
hub / github.com/di-sukharev/opencommit / WritableStreamDefaultWriterCloseWithErrorPropagation

Function WritableStreamDefaultWriterCloseWithErrorPropagation

out/cli.cjs:12604–12614  ·  view source on GitHub ↗
(writer)

Source from the content-addressed store, hash-verified

12602 return WritableStreamClose(stream4);
12603 }
12604 function WritableStreamDefaultWriterCloseWithErrorPropagation(writer) {
12605 const stream4 = writer._ownerWritableStream;
12606 const state2 = stream4._state;
12607 if (WritableStreamCloseQueuedOrInFlight(stream4) || state2 === "closed") {
12608 return promiseResolvedWith(void 0);
12609 }
12610 if (state2 === "errored") {
12611 return promiseRejectedWith(stream4._storedError);
12612 }
12613 return WritableStreamDefaultWriterClose(writer);
12614 }
12615 function WritableStreamDefaultWriterEnsureClosedPromiseRejected(writer, error) {
12616 if (writer._closedPromiseState === "pending") {
12617 defaultWriterClosedPromiseReject(writer, error);

Callers 1

ReadableStreamPipeToFunction · 0.85

Calls 4

promiseResolvedWithFunction · 0.85
promiseRejectedWithFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…