Struct NestedTimerWorkflow

pub struct NestedTimerWorkflow<Context, Action>
where
    Context: Send + Sync + 'static,
    Action: ActionType + Send + Sync + 'static + Default + Debug,
{ /* private fields */ }

A nested timer workflow that can be used as a standard node

Implementations

impl<Context, Action> NestedTimerWorkflow<Context, Action>

where Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Default + Debug,

pub fn new( workflow: Arc<TimerWorkflow<Context, Action>>, complete_action: Action, ) -> Self

Create a new nested timer workflow

pub fn with_id( workflow: Arc<TimerWorkflow<Context, Action>>, id: impl Into<String>, complete_action: Action, ) -> Self

Create a new nested timer workflow with a specific ID

Trait Implementations

impl<Context, Action> Node<Context, Action> for NestedTimerWorkflow<Context, Action>

where Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Default + Debug,

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 Context, ) -> Pin<Box<dyn Future<Output = Result<NodeOutcome<Self::Output, Action>, FloxideError>> + Send + 'async_trait>>

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

Process the node asynchronously