/** Internal pull-wait ownership used by the node-host long poll. */
export class MeetingNodeAudioPullWaiters {
  readonly #waiters = new Set<() => void>();

  get size(): number {
    return this.#waiters.size;
  }

  async wait(timeoutMs: number): Promise<void> {
    let wake!: () => void;
    const ready = new Promise<void>((resolve) => {
      wake = resolve;
      this.#waiters.add(wake);
    });
    let timer: ReturnType<typeof setTimeout> | undefined;
    const timeout = new Promise<void>((resolve) => {
      timer = setTimeout(resolve, timeoutMs);
    });
    try {
      await Promise.race([timeout, ready]);
    } finally {
      // A stalled bridge can be polled indefinitely. Timeout must release its
      // resolver instead of retaining one waiter per empty pull.
      this.#waiters.delete(wake);
      if (timer !== undefined) {
        clearTimeout(timer);
      }
    }
  }

  wake(): void {
    const waiters = [...this.#waiters];
    this.#waiters.clear();
    for (const waiter of waiters) {
      waiter();
    }
  }
}