Struct ExecutionMode 

pub struct ExecutionMode<T, E> { /* private fields */ }

Implementations

impl<T, E> ExecutionMode<T, E>

Auto-generated by derive_getters::Getters.

pub fn execution_fn( &self, ) -> &Option<Box<dyn Fn(Pin<Box<dyn Future<Output = Result<T, E>> + Send + 'static>>) -> JoinHandle<Result<T, E>> + Send + 'static>>

Get field execution_fn from instance of ExecutionMode.

impl<T, E> ExecutionMode<T, E>

pub fn true_async() -> Self

Everything function is executed truly asynchronously For example, if a step has tasks A, B and C, we execute each of them asynchronously.

pub fn pseudo_async<F>(execution_fn: F) -> Self

where F: Fn(Pin<Box<dyn Future<Output = Result<T, E>> + Send + 'static>>) -> JoinHandle<Result<T, E>> + Send + 'static,

All the individual tasks in a step are executed in parallel, but we wait for all the tasks in the same step to complete. For example, if a step has tasks A, B and C, we execute the tasks in parallel and wait for all of them.