Struct TransformNodeAdapter

pub struct TransformNodeAdapter<TN, Input, Output, Error, Action>
where
    TN: TransformNode<Input, Output, Error>,
    Input: Clone + Send + Sync + 'static,
    Output: Clone + Send + Sync + 'static,
    Error: Error + Send + Sync + 'static,
    Action: ActionType + Default + Send + Sync + 'static,
{ /* private fields */ }

Adapter to convert a TransformNode to a LifecycleNode

Implementations

impl<TN, Input, Output, Error, Action> TransformNodeAdapter<TN, Input, Output, Error, Action>

where TN: TransformNode<Input, Output, Error>, Input: Clone + Send + Sync + 'static, Output: Clone + Send + Sync + 'static, Error: Error + Send + Sync + 'static, Action: ActionType + Default + Send + Sync + 'static,

pub fn new(node: TN) -> Self

Create a new adapter for a TransformNode

pub fn with_id(node: TN, id: impl Into<String>) -> Self

Create a new adapter with a specific ID

Trait Implementations

impl<TN, Input, Output, Error, Action> Debug for TransformNodeAdapter<TN, Input, Output, Error, Action>

where TN: TransformNode<Input, Output, Error> + Debug, Input: Clone + Send + Sync + 'static, Output: Clone + Send + Sync + 'static, Error: Error + Send + Sync + 'static, Action: ActionType + Default + Send + Sync + 'static,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<TN, Input, Output, Error, Action> LifecycleNode<TransformContext<Input>, Action> for TransformNodeAdapter<TN, Input, Output, Error, Action>

where TN: TransformNode<Input, Output, Error> + Send + Sync + 'static, Input: Clone + Send + Sync + 'static, Output: Clone + Send + Sync + 'static, Error: Error + Send + Sync + 'static + Into<FloxideError>, Action: ActionType + Default + Send + Sync + 'static,

type PrepOutput = Input

Output type from the preparation phase

type ExecOutput = Output

Output type from the execution phase

fn id(&self) -> NodeId

Get the node’s unique identifier

fn prep<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 mut TransformContext<Input>, ) -> Pin<Box<dyn Future<Output = Result<Self::PrepOutput, FloxideError>> + Send + 'async_trait>>

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

Preparation phase - perform setup and validation

fn exec<'life0, 'async_trait>( &'life0 self, prep_result: Self::PrepOutput, ) -> Pin<Box<dyn Future<Output = Result<Self::ExecOutput, FloxideError>> + Send + 'async_trait>>

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

Execution phase - perform the main work

fn post<'life0, 'life1, 'async_trait>( &'life0 self, _prep_result: Self::PrepOutput, exec_result: Self::ExecOutput, _ctx: &'life1 mut TransformContext<Input>, ) -> Pin<Box<dyn Future<Output = Result<Action, FloxideError>> + Send + 'async_trait>>

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

Post-execution phase - determine the next action and update context