Struct Agent 

pub struct Agent { /* private fields */ }

Stateful wrapper around agent_loop with conversation state, cancellation, event subscription, and message queue management.

Implementations

impl Agent

pub fn new( provider: Box<dyn Provider>, tools: Vec<Box<dyn Tool>>, model: String, system: Option<String>, config: AgentLoopConfig, hooks: Box<dyn AgentHooks>, ) -> Self

Create a new Agent with the given provider, tools, model, and hooks.

pub async fn prompt( &mut self, text: impl Into<String>, ) -> Result<Vec<AgentMessage>, AgentError>

Send a user message and run the agent loop.

Resets the cancellation state if the agent was previously aborted, allowing a fresh conversation turn.

pub async fn continue_( &mut self, text: impl Into<String>, ) -> Result<Vec<AgentMessage>, AgentError>

Continue the conversation with an additional user message.

Requires the last context message to be a user message or tool result.

pub fn abort(&self)

Cancel the current operation.

Equivalent to the first Ctrl+C. The running prompt or continue_ call will return AgentError::Cancelled.

pub fn add_tool(&mut self, tool: Box<dyn Tool>)

Add an additional tool to the agent’s tool set.

pub fn subscribe(&mut self, callback: Box<dyn Fn(&AgentEvent) + Send + Sync>)

Register an event subscriber that receives all AgentEvents.

pub fn cancel_token(&self) -> CancellationToken

Return a clonable cancellation token for external cancellation.

Cancelling this token cancels the currently running loop operation.

pub fn steer(&self, message: String)

Add a steering message to be delivered before the next provider request.

Steering messages are high-priority and delivered after the current turn’s tool calls complete but before the next provider request.

pub fn follow_up(&self, message: String)

Add a follow-up message to be delivered when the agent would otherwise stop.

Follow-up messages are only delivered when the agent has no tool calls pending and no steering messages queued.