Struct LongRunningNodeAdapter 

pub struct LongRunningNodeAdapter<LRN, Context, Action, S>
where
    LRN: LongRunningNode<Context, Action>,
    Context: Send + Sync + 'static,
    Action: ActionType + LongRunningActionExt + Send + Sync + 'static + Debug,
    S: StateStore,
{ /* private fields */ }

An adapter that allows a LongRunningNode to be used as a standard Node. This adapter handles state management and action conversion.

Implementations

impl<LRN, Context, Action, S> LongRunningNodeAdapter<LRN, Context, Action, S>

where LRN: LongRunningNode<Context, Action>, Context: Send + Sync + 'static, Action: ActionType + LongRunningActionExt + Send + Sync + 'static + Debug, S: StateStore,

pub fn new(node: LRN, state_store: S) -> Self

Create a new adapter for a long-running node

pub fn with_suspend_timeout(self, timeout: Duration) -> Self

Set a timeout for suspended nodes

Trait Implementations

impl<LRN, Context, Action, S> Node<Context, Action> for LongRunningNodeAdapter<LRN, Context, Action, S>

where LRN: LongRunningNode<Context, Action>, Context: Send + Sync + 'static, Action: ActionType + LongRunningActionExt + Send + Sync + 'static + Debug, S: StateStore, LRN::Output: Send + Sync + 'static,

type Output = Action

The output type produced by 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

fn id(&self) -> NodeId

Get the unique identifier for this node