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

Function Ke

out/cli.cjs:7595–7604  ·  view source on GitHub ↗
(e3)

Source from the content-addressed store, hash-verified

7593 return e3._pendingAbortRequest._promise = a4, n2 || et(e3, t2), a4;
7594}
7595function Ke(e3) {
7596 const t2 = e3._state;
7597 if ("closed" === t2 || "errored" === t2) return d6(new TypeError(`The stream (in ${t2} state) is not in the writable state and cannot be closed`));
7598 const r3 = u2((t3, r4) => {
7599 const o4 = { _resolve: t3, _reject: r4 };
7600 e3._closeRequest = o4;
7601 }), o3 = e3._writer;
7602 var n2;
7603 return void 0 !== o3 && e3._backpressure && "writable" === t2 && Et(o3), ue2(n2 = e3._writableStreamController, lt, 0), dt(n2), r3;
7604}
7605function Ze(e3, t2) {
7606 "writable" !== e3._state ? tt(e3) : et(e3, t2);
7607}

Callers 1

closeMethod · 0.85

Calls 5

d6Function · 0.85
u2Function · 0.85
EtFunction · 0.85
ue2Function · 0.85
dtFunction · 0.85

Tested by

no test coverage detected