Struct TimerNodeAdapter 

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

An adapter to use a timer node as a standard node

Implementations

impl<Context, Action> TimerNodeAdapter<Context, Action>

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

pub fn new( node: Arc<dyn TimerNode<Context, Action>>, execute_immediately: bool, ) -> Self

Create a new timer node adapter

pub fn with_id( node: Arc<dyn TimerNode<Context, Action>>, id: impl Into<String>, execute_immediately: bool, ) -> Self

Create a new timer node adapter with a specific ID

Trait Implementations

impl<Context, Action> Node<Context, Action> for TimerNodeAdapter<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