Function flush

cli/src/utils/message-updater.ts:134–149

()

  let isDisposed = false

  const flush = () => {
    if (pendingUpdaters.length === 0) return

    // Capture and clear the queue atomically
    const updaters = pendingUpdaters.splice(0, pendingUpdaters.length)

    // Compose all pending updaters into a single transform
    const composedUpdater = (msg: ChatMessage): ChatMessage => {
      return updaters.reduce((m, fn) => fn(m), msg)
    }

    // Apply composed update to the target message
    setMessages((prev) =>
      prev.map((msg) => (msg.id === aiMessageId ? composedUpdater(msg) : msg)),
    )
  }

  const dispose = () => {
    if (isDisposed) return