MCPcopy Create free account
hub / github.com/RtlZeroMemory/Rezi / rejectPending

Function rejectPending

packages/node/src/backend/nodeBackend.ts:255–267  ·  view source on GitHub ↗
(err: Error)

Source from the content-addressed store, hash-verified

253 }
254
255 function rejectPending(err: Error): void {
256 while (eventWaiters.length > 0) eventWaiters.shift()?.reject(err);
257 while (capsWaiters.length > 0) capsWaiters.shift()?.reject(err);
258 while (commitWaiters.length > 0) commitWaiters.shift()?.reject(err);
259 eventQueue.length = 0;
260 rejectFrameWaiters(frameTracking, frameAudit, err);
261 rejectDebugWaiters(debugChannel, err);
262
263 if (startDef !== null && !startSettled) {
264 startSettled = true;
265 startDef.reject(err);
266 }
267 }
268
269 function send(msg: MainToWorkerMessage, transfer?: readonly ArrayBuffer[]): void {
270 if (worker === null) return;

Callers 2

handleWorkerMessageFunction · 0.85
handleWorkerExitFunction · 0.85

Calls 2

rejectFrameWaitersFunction · 0.85
rejectDebugWaitersFunction · 0.85

Tested by

no test coverage detected