Struct SubAgentMiddleware 

pub struct SubAgentMiddleware {
    pub max_iterations: u32,
    /* private fields */
}

Middleware that allows the main agent to delegate tasks to isolated sub-agents.

Provides a SubAgentTool that the main agent can invoke with a task description. The tool spins up a lightweight sub-agent (a single model call), runs it to completion, and returns the sub-agent’s output.

Fields

max_iterations: u32

Maximum number of iterations a sub-agent may run.

Implementations

impl SubAgentMiddleware

pub fn new(model: Arc<dyn BaseChatModel>, max_iterations: u32) -> Self

Create a new SubAgentMiddleware with the given model and iteration limit.

pub fn tools(&self) -> Vec<Arc<dyn BaseTool>>

Return the set of tools this middleware provides.

pub async fn subagents(&self) -> HashMap<String, SubAgentHandle>

Get a snapshot of all sub-agent handles.

Trait Implementations

impl Middleware for SubAgentMiddleware

fn name(&self) -> &str

A human-readable name for this middleware.

fn before_model<'life0, 'life1, 'async_trait>( &'life0 self, _state: &'life1 mut AgentState, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called before the model is invoked. Can mutate the state (e.g. inject context).

fn after_model<'life0, 'life1, 'async_trait>( &'life0 self, _state: &'life1 mut AgentState, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called after the model responds. Can inspect or mutate the state.

fn before_tool<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _state: &'life1 mut AgentState, _tool_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called before a tool is executed.

fn gate_tool<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _state: &'life1 mut AgentState, _tool_name: &'life2 str, _tool_input: &'life3 Value, ) -> Pin<Box<dyn Future<Output = Result<ToolGateDecision>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Called before a tool is executed, with an opportunity to short-circuit.

fn after_tool<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _state: &'life1 mut AgentState, _tool_name: &'life2 str, _result: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Called after a tool execution completes.