Method WaitForActivity

agent/tools_executor.go:179–194

(ctx context.Context)

			}
		}
	}
	return results
}

func (e *StreamingToolExecutor) HasPendingWork() bool {
	e.mu.Lock()
	defer e.mu.Unlock()
	for _, slot := range e.slots {
		if slot.State == ToolStateQueued || slot.State == ToolStateExecuting {
			return true
		}
	}
	return false
}

func (e *StreamingToolExecutor) WaitForActivity(ctx context.Context) {
	if !e.HasPendingWork() {
		return
	}