Struct Runner 

pub struct Runner<O: Serialize + Send + Sync + 'static = ()> { /* private fields */ }

Drives the agent execution loop.

The runner is stateless between runs; all per-run state is held in the channel and local variables inside run.

Implementations

impl<O: Serialize + Send + Sync + 'static> Runner<O>

pub fn new(agent: Agent<O>) -> Self

Create a runner wrapping the given agent.

pub async fn set_model(&self, model: impl Into<String>)

Dynamically switch the model for subsequent turns, preserving conversation history.

pub async fn stop_graceful(&self)

Send a graceful stop signal. The runner will finish any in-flight tool call, then emit TurnComplete { reason: Stopped }.

pub async fn stop_force(&self)

Send a force stop signal. The runner cancels immediately and emits TurnComplete { reason: Aborted }.

pub async fn run( &self, input: Value, config: RunnerConfig, ) -> Result<Receiver<AgentEvent>, AgentError>

Run the agent with the given input, yielding events over a channel.

Event stream

Events are sent on the returned receiver. The stream ends when the receiver is closed (after a TurnComplete or Error event).

Errors

Returns AgentError if setup fails before the event stream starts.

Trait Implementations

impl<O: Debug + Serialize + Send + Sync + 'static> Debug for Runner<O>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.