Struct ParallelExecutor 

pub struct ParallelExecutor { /* private fields */ }

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

How it works

1. Groups tool calls by tool name
2. Executes each group in parallel using Tool::call_batch
3. Flattens and returns all results

Example

Given tool calls:

[
  ToolCall { id: "1", function: { name: "weather", ... } },
  ToolCall { id: "2", function: { name: "search", ... } },
  ToolCall { id: "3", function: { name: "weather", ... } },
]

The executor will:

1. Group by name: { "weather": [call1, call3], "search": [call2] }
2. Execute in parallel:
   • weather_tool.call_batch([call1, call3]) (runs concurrently)
   • search_tool.call_batch([call2]) (runs concurrently)
3. Return flattened results: [result1, result3, result2]

Implementations

impl ParallelExecutor

pub fn new() -> Self

Create a new parallel executor

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<ToolMessage>> + Send + 'async_trait>>

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

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