Struct SimpleLongRunningNode

pub struct SimpleLongRunningNode<Context, Action, State, Output, F>
where
    Context: Send + Sync + 'static,
    Action: ActionType + Send + Sync + 'static + Debug,
    State: Serialize + for<'de> Deserialize<'de> + Send + Sync + 'static,
    Output: Send + Sync + 'static,
    F: Fn(Option<State>, &mut Context) -> Result<LongRunningOutcome<Output, State>, FloxideError> + Send + Sync + 'static,
{ /* private fields */ }

A simple long-running node that uses a closure for processing.

Implementations

impl<Context, Action, State, Output, F> SimpleLongRunningNode<Context, Action, State, Output, F>

where Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Debug, State: Serialize + for<'de> Deserialize<'de> + Send + Sync + 'static, Output: Send + Sync + 'static, F: Fn(Option<State>, &mut Context) -> Result<LongRunningOutcome<Output, State>, FloxideError> + Send + Sync + 'static,

pub fn new(process_fn: F) -> Self

Create a new SimpleLongRunningNode with a unique ID

pub fn with_id(id: impl Into<NodeId>, process_fn: F) -> Self

Create a new SimpleLongRunningNode with a specified ID

Trait Implementations

impl<Context, Action, State, Output, F> LongRunningNode<Context, Action> for SimpleLongRunningNode<Context, Action, State, Output, F>

where Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Debug, State: Serialize + for<'de> Deserialize<'de> + Send + Sync + 'static, Output: Send + Sync + 'static, F: Fn(Option<State>, &mut Context) -> Result<LongRunningOutcome<Output, State>, FloxideError> + Send + Sync + 'static,

type State = State

Type representing the node’s processing state

type Output = Output

Type representing the final output

fn process<'life0, 'life1, 'async_trait>( &'life0 self, state: Option<Self::State>, ctx: &'life1 mut Context, ) -> Pin<Box<dyn Future<Output = Result<LongRunningOutcome<Self::Output, Self::State>, FloxideError>> + Send + 'async_trait>>

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

Process the next step, potentially suspending execution

fn id(&self) -> NodeId

Get the node’s unique identifier