Struct AgentEventRunnable 

pub struct AgentEventRunnable { /* private fields */ }

Adapter that wraps an AgentExecutor as Runnable<String, AgentStreamEvent>.

Unlike AgentRunnable, stream() preserves all AgentStreamEvent variants (Text / ToolStart / ToolEnd / FinalAnswer / Error) instead of filtering down to FinalAnswer. Use this in LCEL pipelines when you need the fused tool-event + text-token stream (P1-8).

Non-streaming invoke() runs the agent and returns the final answer as a single AgentStreamEvent::FinalAnswer.

Implementations

impl AgentEventRunnable

pub fn new(executor: Arc<AgentExecutor>) -> Self

Wrap an executor, exposing its full event stream.

Trait Implementations

impl Runnable<String, AgentStreamEvent> for AgentEventRunnable

type Error = LcelError

Error type.

fn invoke<'life0, 'async_trait>( &'life0 self, input: String, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<AgentStreamEvent, LcelError>> + Send + 'async_trait>>

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

Transforms single input to output.

fn stream<'life0, 'async_trait>( &'life0 self, input: String, _config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<AgentStreamEvent, LcelError>> + Send>>, LcelError>> + Send + 'async_trait>>

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

Streaming output - for real-time responses (LLM, etc).

fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Output>, Self::Error>> + Send + 'async_trait>>

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

Batch processing - transforms multiple inputs to outputs.

fn batch_as_completed<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Vec<(usize, Output)>, Self::Error>> + Send + 'async_trait>>

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

Batch processing that returns results in completion order.

fn transform<'life0, 'async_trait>( &'life0 self, input: Pin<Box<dyn Stream<Item = Result<Input, Self::Error>> + Send>>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<Output, Self::Error>> + Send + 'life0>>, Self::Error>> + Send + 'async_trait>>

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

Stream-to-stream transformation - the core of LCEL streaming.