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

Function onFinished

out/cli.cjs:55163–55184  ·  view source on GitHub ↗
(err)

Source from the content-addressed store, hash-verified

55161 };
55162 const onAbort = function() {
55163 if (finished) {
55164 return;
55165 }
55166 const err = new RequestAbortedError();
55167 queueMicrotask(() => onFinished(err));
55168 };
55169 const onFinished = function(err) {
55170 if (finished) {
55171 return;
55172 }
55173 finished = true;
55174 assert2(socket.destroyed || socket[kWriting] && client[kRunning] <= 1);
55175 socket.off("drain", onDrain).off("error", onFinished);
55176 body.removeListener("data", onData).removeListener("end", onFinished).removeListener("error", onFinished).removeListener("close", onAbort);
55177 if (!err) {
55178 try {
55179 writer.end();
55180 } catch (er2) {
55181 err = er2;
55182 }
55183 }
55184 writer.destroy(err);
55185 if (err && (err.code !== "UND_ERR_INFO" || err.message !== "reset")) {
55186 util4.destroy(body, err);
55187 } else {

Callers 2

onAbortFunction · 0.85
cli.cjsFile · 0.85

Calls 5

removeListenerMethod · 0.80
endMethod · 0.80
offMethod · 0.45
destroyMethod · 0.45
unsubscribeMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…