Trait StreamingToolExecutor 

pub trait StreamingToolExecutor: Send + Sync {
    type Item: Serialize + Send;
    type Error: Error + Send + Sync + 'static;

    // Required method
    fn execute_stream<'a>(
        &'a self,
        ctx: &'a ExecutionContext,
    ) -> Pin<Box<dyn Stream<Item = Result<Self::Item, Self::Error>> + Send + 'a>>;
}

Trait for tools that produce streaming output

Required Associated Types

type Item: Serialize + Send

type Error: Error + Send + Sync + 'static

Required Methods

fn execute_stream<'a>( &'a self, ctx: &'a ExecutionContext, ) -> Pin<Box<dyn Stream<Item = Result<Self::Item, Self::Error>> + Send + 'a>>

Implementors