Method close

packages/runtime/src/async-queue.ts:120–128

()

  }

  close(): void {
    if (this.closed) return;
    this.closed = true;
    while (this.waiters.length > 0) {
      const w = this.waiters.shift()!;
      w.resolve({ value: undefined as unknown as T, done: true });
    }
    this.wake();
  }

  error(err: Error): void {
    if (this.closed) return;