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

Function WritableStreamClose

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

Source from the content-addressed store, hash-verified

12284 return promise;
12285 }
12286 function WritableStreamClose(stream4) {
12287 const state2 = stream4._state;
12288 if (state2 === "closed" || state2 === "errored") {
12289 return promiseRejectedWith(new TypeError(`The stream (in ${state2} state) is not in the writable state and cannot be closed`));
12290 }
12291 const promise = newPromise((resolve, reject) => {
12292 const closeRequest = {
12293 _resolve: resolve,
12294 _reject: reject
12295 };
12296 stream4._closeRequest = closeRequest;
12297 });
12298 const writer = stream4._writer;
12299 if (writer !== void 0 && stream4._backpressure && state2 === "writable") {
12300 defaultWriterReadyPromiseResolve(writer);
12301 }
12302 WritableStreamDefaultControllerClose(stream4._writableStreamController);
12303 return promise;
12304 }
12305 function WritableStreamAddWriteRequest(stream4) {
12306 const promise = newPromise((resolve, reject) => {
12307 const writeRequest = {

Callers 2

closeMethod · 0.85

Calls 4

promiseRejectedWithFunction · 0.85
newPromiseFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…