Struct AgentHandle 

pub struct AgentHandle { /* private fields */ }

A handle to the agent that can be used by the interpreter.

This is cloneable so it can be passed to different interpreter threads. Uses tokio’s UnboundedSender which allows non-blocking sends from sync code.

Implementations

impl AgentHandle

pub fn new(tx: UnboundedSender<ThinkRequest>) -> Self

Create a new agent handle from a sender.

pub fn think( &self, prompt: String, bindings: HashMap<String, Value>, expect: String, ) -> Result<Receiver<ThinkResponse>, String>

Send a think request to the agent.

Returns a receiver for ThinkResponse messages. The send is non-blocking (uses tokio unbounded channel), but the returned receiver is std::sync for blocking receive.

Trait Implementations

impl Clone for AgentHandle

fn clone(&self) -> AgentHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.