Struct SubagentHandle 

pub struct SubagentHandle {
    pub id: String,
    pub agent_name: String,
    pub task_preview: String,
    pub model: String,
    pub system_prompt: String,
    pub started_at: Instant,
    pub timeout_secs: u64,
    /* private fields */
}

Fields

id: String

agent_name: String

task_preview: String

model: String

system_prompt: String

started_at: Instant

timeout_secs: u64

Implementations

impl SubagentHandle

pub fn new( id: String, agent_name: String, task_preview: String, model: String, system_prompt: String, timeout_secs: u64, state: Arc<RwLock<SubagentState>>, steer_tx: Option<UnboundedSender<String>>, shutdown_tx: Option<Sender<()>>, result_rx: Option<Receiver<SubagentResult>>, ) -> Self

Construct a new handle. The state Arc is shared with the spawned subagent thread.

pub fn status(&self) -> SubagentStatus

Current status snapshot.

pub fn partial_output(&self) -> String

Partial output accumulated so far.

pub fn tool_log(&self) -> Vec<String>

Snapshot of the tool log.

pub fn conversation_state(&self) -> Vec<Value>

Snapshot of conversation state (for resume).

pub fn elapsed_secs(&self) -> f64

Seconds since this handle was created.

pub fn steer(&self, message: &str) -> Result<(), String>

Send a steering message into the running subagent.

pub fn set_thread_handle(&mut self, handle: JoinHandle<()>)

Signal the subagent to shut down. Store the OS thread handle for graceful shutdown.

pub fn cancel(&mut self)

pub fn is_finished(&self) -> bool

True if the subagent is no longer running.

pub async fn collect(self) -> Result<SubagentResult, String>

Consume the handle and wait for the final result.

Trait Implementations

impl Debug for SubagentHandle

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

Formats the value using the given formatter.