Method end

packages/ai-acp/src/stream/queue.ts:25–31

()

  }

  end(): void {
    if (this.ended || this.failed) return
    this.ended = true
    for (const waiter of this.waiters.splice(0)) {
      waiter.resolve({ value: undefined, done: true })
    }
  }

  fail(error: unknown): void {
    if (this.ended || this.failed) return