Method fail

packages/ai-acp/src/stream/queue.ts:33–40

(error: unknown)

  }

  fail(error: unknown): void {
    if (this.ended || this.failed) return
    this.failed = true
    this.error = error
    for (const waiter of this.waiters.splice(0)) {
      waiter.reject(error)
    }
  }

  [Symbol.asyncIterator](): AsyncIterator<T> {
    return {