Method push

packages/ai-opencode/src/stream/queue.ts:16–24

(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)
    }
  }

  /** Signal normal completion; pending and future reads resolve as done. */
  end(): void {