Struct RunnableSequence 

pub struct RunnableSequence<I, O> { /* private fields */ }

Implementations

impl<I: Send + 'static, O: Send + 'static> RunnableSequence<I, O>

pub fn new(runnable: impl Runnable<I, O> + Send + Sync + 'static) -> Self

Trait Implementations

impl<I: 'static + Send, O: 'static + Send> Runnable<I, O> for RunnableSequence<I, O>

fn invoke( &self, input: I, ) -> Pin<Box<dyn Future<Output = Result<O, Error>> + Send>>

fn clone_to_owned(&self) -> Box<dyn Runnable<I, O> + Send + Sync>

fn invoke_with_config( &self, input: I, _config: Option<HashMap<String, Value>>, ) -> Pin<Box<dyn Future<Output = Result<O, Error>> + Send>>

fn batch( &self, inputs: Vec<I>, ) -> Pin<Box<dyn Future<Output = Vec<Result<O, Error>>> + Send>>

fn batch_with_config( &self, inputs: Vec<I>, _config: Option<HashMap<String, Value>>, ) -> Pin<Box<dyn Future<Output = Vec<Result<O, Error>>> + Send>>

fn stream(&self, input: I) -> Box<dyn Stream<Item = Result<O, Error>> + Send>

fn astream( &self, _input: I, ) -> Pin<Box<dyn Future<Output = Box<dyn Stream<Item = Result<O, Error>> + Send>> + Send>>