(runId: string, threadId: string)
| 801 | // the matching RUN_STARTED chunk from the adapter lands later and |
| 802 | // observeChunk keeps the same context. |
| 803 | beginRun(runId: string, threadId: string): void { |
| 804 | this.currentRunId = runId |
| 805 | this.currentRunThreadId = threadId |
| 806 | this.lastRunEventContext = { runId, threadId } |
| 807 | } |
| 808 | |
| 809 | observeChunk(chunk: StreamChunk): void { |
| 810 | if (chunk.type === 'RUN_STARTED') { |
no outgoing calls
no test coverage detected