Struct ParallelExecutor 

pub struct ParallelExecutor { /* private fields */ }

Executes tools in parallel by grouping calls by tool name and using Tool::call_batch

Implementations

impl ParallelExecutor

pub fn new() -> Self

Trait Implementations

impl ToolExecutor for ParallelExecutor

fn add( &mut self, name: String, tool: Box<dyn Tool + Sync>, ) -> Option<Box<dyn Tool + Sync>>

Adds a tool to the executor. Returns the previous tool with the same name if it exists.

fn execute<'life0, 'async_trait>( &'life0 self, calls: Vec<ToolCall>, ) -> Pin<Box<dyn Future<Output = Vec<Message>> + Send + 'async_trait>>

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

Executes the given tool calls and returns the results as messages.