MCPcopy Create free account
hub / github.com/MoonshotAI/kimi-code / abortableSleep

Function abortableSleep

packages/telemetry/src/transport.ts:327–338  ·  view source on GitHub ↗
(ms: number, signal?: AbortSignal)

Source from the content-addressed store, hash-verified

325}
326
327function abortableSleep(ms: number, signal?: AbortSignal): Promise<void> {
328 if (signal?.aborted === true) return Promise.reject(abortError());
329 return new Promise((resolve, reject) => {
330 const timer = setTimeout(resolve, ms);
331 timer.unref?.();
332 const onAbort = (): void => {
333 clearTimeout(timer);
334 reject(abortError());
335 };
336 signal?.addEventListener('abort', onAbort, { once: true });
337 });
338}
339
340function isAbortError(error: unknown): boolean {
341 return error instanceof Error && error.name === 'AbortError';

Callers

nothing calls this directly

Calls 2

abortErrorFunction · 0.70
rejectMethod · 0.65

Tested by

no test coverage detected