Struct NestedEventDrivenWorkflow 

pub struct NestedEventDrivenWorkflow<E, C, A>
where
    E: Send + 'static,
    C: Send + Sync + 'static,
    A: ActionType + Send + Sync + 'static + Default,
{ /* private fields */ }

A nested event-driven workflow that can be used in a standard workflow

Implementations

impl<E, C, A> NestedEventDrivenWorkflow<E, C, A>

where E: Send + 'static, C: Send + Sync + 'static, A: ActionType + Send + Sync + 'static + Default,

pub fn new( workflow: Arc<EventDrivenWorkflow<E, C, A>>, complete_action: A, timeout_action: A, ) -> Self

Create a new nested workflow without a timeout

pub fn with_timeout( workflow: Arc<EventDrivenWorkflow<E, C, A>>, timeout: Duration, complete_action: A, timeout_action: A, ) -> Self

Create a new nested workflow with a timeout

pub fn with_id( workflow: Arc<EventDrivenWorkflow<E, C, A>>, id: impl Into<String>, complete_action: A, timeout_action: A, ) -> Self

Create a new nested workflow with a specific ID

Trait Implementations

impl<E, C, A> Node<C, A> for NestedEventDrivenWorkflow<E, C, A>

where E: Send + 'static, C: Send + Sync + 'static, A: ActionType + Send + Sync + 'static + Default,

type Output = ()

The output type produced by this node

fn id(&self) -> NodeId

Get the unique identifier for this node

fn process<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 mut C, ) -> Pin<Box<dyn Future<Output = Result<NodeOutcome<Self::Output, A>, FloxideError>> + Send + 'async_trait>>

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

Process the node asynchronously