Struct Agent 

pub struct Agent { /* private fields */ }

A stateful agent. Clone shares the same inner state + event channel (like holding a second reference to the TS Agent instance).

Implementations

impl Agent

pub fn subscribe(&self) -> Receiver<AgentEvent>

Subscribe to agent lifecycle events. Returns a broadcast::Receiver. Mirrors TS subscribe.

pub fn state(&self) -> AgentState

Current agent state snapshot. Clones tools/messages so callers can’t mutate internal state. Mirrors TS get state().

pub fn steer(&self, message: AgentMessage)

Queue a steering message (injected after the current turn’s tool batch).

pub fn follow_up(&self, message: AgentMessage)

Queue a follow-up message (injected when the agent would otherwise stop).

pub fn has_queued_messages(&self) -> bool

True when either queue has pending messages.

pub fn abort(&self)

Abort the current run, if one is active. No-op otherwise.

pub async fn wait_for_idle(&self)

Resolve when the current run finishes (or immediately if idle).

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

Start a new prompt from text. Convenience for prompt_message.

pub async fn prompt_message( &self, message: AgentMessage, ) -> Result<(), AgentError>

Start a new prompt from a single AgentMessage.

pub async fn prompt_messages( &self, messages: Vec<AgentMessage>, ) -> Result<(), AgentError>

Start a new prompt from a batch of AgentMessages.

pub async fn continue_run(&self) -> Result<(), AgentError>

Continue from the current transcript. Errors if the agent is busy or the last message is an assistant message with no queued steering/follow-up.

pub fn reset(&self) -> Result<(), AgentError>

Clear transcript + runtime state + queues. Errors if a run is active.

Trait Implementations

impl Clone for Agent

fn clone(&self) -> Agent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.