Struct StreamingToolExecutor 

pub struct StreamingToolExecutor { /* private fields */ }

Executes tools as they stream in with concurrency control. Rust port of TypeScript’s StreamingToolExecutor class.

• Concurrency-safe tools can execute in parallel
• Non-concurrent tools must execute exclusively

Uses Arc<Mutex> for interior mutability so it can be shared via Arc and called from the SSE parsing loop, while spawned tasks can also access the state for marking completions.

Implementations

impl StreamingToolExecutor

pub fn new(parent_abort: Arc<AtomicBool>) -> Self

pub fn discard(&self)

Discard all pending and in-progress tools. Called when streaming fallback occurs.

pub fn add_tool(&self, tool_use_block: Value, is_concurrency_safe: bool)

Add a tool to the execution queue.

pub fn has_unfinished_tools(&self) -> bool

Check if there are any unfinished tools

pub fn get_completed_results(&self) -> Vec<(String, Value)>

Get completed results that haven’t been yielded. Stops on non-concurrency-safe executing tool (yielding order).

pub fn mark_tool_errored(&self, tool_id: &str, _description: &str)

Mark a tool as having errored (cascading error for sibling tools).

pub fn summary(&self) -> String

Get the current state summary for debugging

pub async fn execute_all( &self, executor_fn: SharedExecutorFn, ) -> Vec<(String, Result<ToolResult, AgentError>)>

Execute queued tools with concurrency control. Spawns each tool as a task and waits for results respecting concurrency limits. Returns list of (tool_id, result) pairs in execution order.