Struct StateMachineIntegrationProcessor

pub struct StateMachineIntegrationProcessor { /* private fields */ }

State machine integration processor

This processor integrates the message processing pipeline with the transaction state machine. It processes incoming TAP messages and updates transaction state accordingly.

Implementations

impl StateMachineIntegrationProcessor

pub fn new() -> Self

Create a new state machine integration processor

pub fn with_state_processor( self, processor: Arc<dyn TransactionStateProcessor>, ) -> Self

Set the state processor

Trait Implementations

impl Clone for StateMachineIntegrationProcessor

fn clone(&self) -> StateMachineIntegrationProcessor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StateMachineIntegrationProcessor

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

Formats the value using the given formatter.

impl Default for StateMachineIntegrationProcessor

fn default() -> Self

Returns the “default value” for a type.

impl PlainMessageProcessor for StateMachineIntegrationProcessor

fn process_incoming<'life0, 'async_trait>( &'life0 self, message: PlainMessage, ) -> Pin<Box<dyn Future<Output = Result<Option<PlainMessage>>> + Send + 'async_trait>>

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

Process an incoming message received by the node

fn process_outgoing<'life0, 'async_trait>( &'life0 self, message: PlainMessage, ) -> Pin<Box<dyn Future<Output = Result<Option<PlainMessage>>> + Send + 'async_trait>>

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

Process an outgoing message being sent from the node