Method flush

src/web-ui/src/flow_chat/services/EventBatcher.ts:170–196

()

  }

  private flush(): void {
    if (this.buffer.size === 0) return;

    const startTime = nowMs();
    const bufferedEvents = Array.from(this.buffer.values());
    const logPayload = getBatchedEventsLogPayload(bufferedEvents);
    const { rawEventCount, mergedEventCount } = logPayload;

    const events = bufferedEvents.map(({ key, payload }) => ({
      key,
      payload
    }));

    log.trace('Flushing batched events', logPayload);

    this.buffer = new Map();
    this.onFlush(events);

    const durationMs = elapsedMs(startTime);
    if (durationMs > 10) {
      log.warn('Event batch processing took longer than expected', {
        rawEventCount,
        mergedEventCount,
        durationMs,
      });
    }
  }

  flushNow(): void {
    if (this.frameId !== null) {