Struct ErrorHandlerNode 

pub struct ErrorHandlerNode<S: State> { /* private fields */ }

Node wrapper that adds error recovery handling

Wraps an inner node and invokes the error handler when the inner node fails, allowing the graph to recover from errors gracefully.

The error handler receives the error and produces a fallback state update. Since the inner node consumes the input state, the handler receives a state snapshot.

Implementations

impl<S: State> ErrorHandlerNode<S>

pub fn new( inner: Arc<dyn Node<S>>, handler: Arc<dyn Fn(NodeError<S>) -> Command<S> + Send + Sync>, ) -> Self

Create a new error handler node

Arguments

• inner - The node to wrap
• handler - Function invoked when inner returns an error, receiving NodeError with detailed information and producing a fallback command

Trait Implementations

impl<S: State> Debug for ErrorHandlerNode<S>

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

Formats the value using the given formatter.

impl<S: State + Clone> Node<S> for ErrorHandlerNode<S>

fn call( &self, state: &S, config: &RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Command<S>, JunctureError>> + Send + '_>>

Execute the node logic

fn name(&self) -> &str

Get the node name

fn call_arc( &self, state: Arc<S>, config: &RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Command<S>, JunctureError>> + Send + '_>>

Execute node logic with Arc<S> to avoid O(N) state clone.