Method GetCompletedResults

agent/tools_executor.go:149–166

()

	e.signalActivity()
}

func (e *StreamingToolExecutor) IsQueued(tcID string) bool {
	e.mu.Lock()
	defer e.mu.Unlock()
	slot := e.slots[tcID]
	return slot != nil && slot.State == ToolStateQueued
}

func (e *StreamingToolExecutor) IsRunning(tcID string) bool {
	e.mu.Lock()
	defer e.mu.Unlock()
	slot := e.slots[tcID]
	return slot != nil && slot.State == ToolStateExecuting
}

func (e *StreamingToolExecutor) GetCompletedResults() []map[string]any {
	e.mu.Lock()
	defer e.mu.Unlock()
	var results []map[string]any
	for _, tid := range e.toolOrder {
		slot := e.slots[tid]