Struct Chain 

pub struct Chain<Head, Tail, Mid> { /* private fields */ }

Implementations

impl<Head, Tail, Mid> Chain<Head, Tail, Mid>

pub fn new(head: Head, tail: Tail) -> Self

Trait Implementations

impl<Input, Mid, Output, Head, Tail> Runnable<Input, Output> for Chain<Head, Tail, Mid>

where Input: Send + 'static, Mid: Send + Sync + 'static, Output: Send + 'static, Head: Runnable<Input, Mid> + Send + Sync, Tail: Runnable<Mid, Output> + Send + Sync,

fn invoke<'life0, 'async_trait>( &'life0 self, input: Input, ) -> Pin<Box<dyn Future<Output = Result<Output, WesichainError>> + Send + 'async_trait>>

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

fn stream( &self, input: Input, ) -> BoxStream<'_, Result<StreamEvent, WesichainError>>

fn to_serializable(&self) -> Option<SerializableRunnable>

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

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

fn abatch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, ) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>

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