Method observeChunk

packages/ai-client/src/devtools.ts:809–829

(chunk: StreamChunk)

  }

  observeChunk(chunk: StreamChunk): void {
    if (chunk.type === 'RUN_STARTED') {
      this.beginRun(chunk.runId, chunk.threadId)
      return
    }

    if (chunk.type === 'RUN_FINISHED' || chunk.type === 'RUN_ERROR') {
      const runId =
        chunk.type === 'RUN_FINISHED'
          ? chunk.runId
          : (chunk as { runId?: string }).runId
      if (!runId || runId === this.currentRunId) {
        const context = this.getCurrentRunEventContext()
        if (context) {
          this.lastRunEventContext = context
        }
        this.currentRunId = null
        this.currentRunThreadId = null
      }
    }
  }

  getCurrentRunEventContext(): ChatClientRunEventContext | undefined {
    if (!this.currentRunId) return undefined