Method push

packages/ai-acp/src/stream/queue.ts:15–23

(value: T)

  private failed = false

  push(value: T): void {
    if (this.ended || this.failed) return
    const waiter = this.waiters.shift()
    if (waiter) {
      waiter.resolve({ value, done: false })
    } else {
      this.values.push(value)
    }
  }

  end(): void {
    if (this.ended || this.failed) return