Method flushStreamEventBuffer

src/cli/transports/ccrClient.ts:771–786

* Drain the stream_event delay buffer: accumulate text_deltas into * full-so-far snapshots, clear the timer, enqueue the resulting events. * Called from the timer, from writeEvent on a non-stream message, and from * flush(). close() drops the buffer — call flush() first if you need * del

()

   * delivery.
   */
  private async flushStreamEventBuffer(): Promise<void> {
    if (this.streamEventTimer) {
      clearTimeout(this.streamEventTimer)
      this.streamEventTimer = null
    }
    if (this.streamEventBuffer.length === 0) return
    const buffered = this.streamEventBuffer
    this.streamEventBuffer = []
    const payloads = accumulateStreamEvents(
      buffered,
      this.streamTextAccumulator,
    )
    await this.eventUploader.enqueue(
      payloads.map(payload => ({ payload, ephemeral: true })),
    )
  }

  /**
   * Write an internal worker event via POST /sessions/{id}/worker/internal-events.