Struct TransformContext

pub struct TransformContext<Input> {
    pub input: Input,
}

Context wrapper for TransformNode

Fields

input: Input

Implementations

impl<Input> TransformContext<Input>

pub fn new(input: Input) -> Self

Create a new transform context

Trait Implementations

impl<Input: Clone> Clone for TransformContext<Input>

fn clone(&self) -> TransformContext<Input>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Input: Debug> Debug for TransformContext<Input>

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