Struct AgentRunner 

pub struct AgentRunner { /* private fields */ }

AgentRunner composes multiple runners into a single unified stream with optional global analyzers applied to the merged stream.

Implementations

impl AgentRunner

pub fn new() -> AgentRunner

pub fn add_runner(self, runner: Box<dyn Runner>) -> AgentRunner

pub fn add_global_analyzer(self, analyzer: Box<dyn Analyzer>) -> AgentRunner

pub fn runner_count(&self) -> usize

pub fn analyzer_count(&self) -> usize

Trait Implementations

impl Default for AgentRunner

fn default() -> AgentRunner

Returns the “default value” for a type.

impl Runner for AgentRunner

fn run<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Event> + Send>>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, AgentRunner: 'async_trait,

fn add_analyzer(self, analyzer: Box<dyn Analyzer>) -> AgentRunner