Function abortableSleep

shift/shift.ts:547–572

(ms: number, signal?: AbortSignal)

    }, ms);

    const onAbort = () => {
      cleanup();
      reject(new DOMException("Operation aborted", "AbortError"));
    };

    const cleanup = () => {
      clearTimeout(timer);
      signal?.removeEventListener("abort", onAbort);
    };

    signal?.addEventListener("abort", onAbort, { once: true });
  });
}

// ====== Group forwarding helpers ======
const groupBuffers = new Map<
  string,
  {
    messages: any[];
    timer: TimerHandle | null;
    sourceId: number;
    targetId: number;
    options?: { silent?: boolean; replyTo?: number };
    shouldForward?: boolean;
    disposeTimer?: () => void | Promise<void>;
  }
>();

function cleanupGroupBuffers(): void {