Struct AgentRunner 

pub struct AgentRunner { /* private fields */ }

Runner for managing multiple concurrent agent executions

Implementations

impl AgentRunner

pub fn new(capacity: usize) -> Self

Create a new runner with the specified channel capacity

pub fn event_sender(&self) -> Sender<AgentEvent>

Get a clone of the event sender for spawning agents

pub async fn spawn(&mut self, config: SpawnConfig) -> Result<()>

Spawn an agent and track its handle

pub async fn recv_event(&mut self) -> Option<AgentEvent>

Receive the next event (blocks until available)

pub fn try_recv_event(&mut self) -> Option<AgentEvent>

Try to receive an event without blocking

pub async fn wait_all(&mut self) -> Vec<AgentResult>

Wait for all spawned agents to complete

pub fn active_count(&self) -> usize

Check how many agents are still running