Struct RunnableAnyWrapper 

pub struct RunnableAnyWrapper<I, O, R>
where
    I: Send + Sync + 'static,
    O: Send + Sync + 'static,
    R: Runnable<I, O>,
{ /* private fields */ }

Wrapper that implements RunnableAny for any Runnable<I, O>.

We use a concrete wrapper struct instead of a blanket impl because Rust’s orphan rules and type parameter constraints make a blanket impl<I, O, R> RunnableAny for R impossible (I and O would be unconstrained).

Implementations

impl<I, O, R> RunnableAnyWrapper<I, O, R>

where I: Send + Sync + 'static, O: Send + Sync + 'static, R: Runnable<I, O>,

pub fn new(runnable: R) -> Self

Create a new wrapper.

Trait Implementations

impl<I, O, R> RunnableAny for RunnableAnyWrapper<I, O, R>

where I: Send + Sync + 'static, O: Send + Sync + 'static, R: Runnable<I, O> + 'static, R::Error: Into<LcelError>,

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

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

Type-erased invoke: Box<dyn Any + Send> → Box<dyn Any + Send>.

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

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

Type-erased stream: Box<dyn Any + Send> → Stream of Box<dyn Any + Send>.

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

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

Type-erased transform: Stream of Box<dyn Any + Send> → Stream of Box<dyn Any + Send>.

fn batch_any<'life0, 'async_trait>( &'life0 self, inputs: Vec<Box<dyn Any + Send>>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Box<dyn Any + Send>>, LcelError>> + Send + 'async_trait>>

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

Type-erased batch: Vec<Box<dyn Any + Send>> → Vec<Box<dyn Any + Send>>.