Struct RunnableWithFallbacks 

pub struct RunnableWithFallbacks<Input, Output> { /* private fields */ }

Implementations

impl<Input, Output> RunnableWithFallbacks<Input, Output>

pub fn new( primary: Arc<dyn Runnable<Input, Output> + Send + Sync>, fallbacks: Vec<Arc<dyn Runnable<Input, Output> + Send + Sync>>, ) -> Self

Trait Implementations

impl<Input, Output> Runnable<Input, Output> for RunnableWithFallbacks<Input, Output>

where Input: Clone + Send + Sync + 'static, Output: Send + Sync + 'static,

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,