(tcID, content, truncated string, isError bool)
| 489 | } |
| 490 | e.mu.Unlock() |
| 491 | e.cancelAll() |
| 492 | } |
| 493 | } |
| 494 | |
| 495 | func (e *StreamingToolExecutor) executionContextForSlot(abort <-chan struct{}) coretools.ExecutionContext { |
| 496 | execCtx := coretools.ExecutionContext{} |
| 497 | for k, v := range e.Context { |
| 498 | execCtx[k] = v |
| 499 | } |
| 500 | execCtx["abort_event"] = abort |
| 501 | return execCtx |
| 502 | } |
| 503 | |
| 504 | func (e *StreamingToolExecutor) preserveAbortResult(tcID string) bool { |
no outgoing calls
no test coverage detected