Struct RuntimeChain 

pub struct RuntimeChain { /* private fields */ }

A runtime-constructed chain that operates on Value. This is used for deserialization where types are not known at compile time.

Implementations

impl RuntimeChain

pub fn new(steps: Vec<Arc<dyn Runnable<Value, Value>>>) -> Self

Trait Implementations

impl Runnable<Value, Value> for RuntimeChain

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

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

fn stream<'a>( &'a self, input: Value, ) -> BoxStream<'a, 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,