Struct Backend 

pub struct Backend { /* private fields */ }

Backend handles inbound custom messages from the Swarm, routing each decoded Envelope to its namespace’s protocol via the Extensions registry. The registry is shared with the Provider, so protocols registered there are visible to inbound dispatch here. Each protocol’s interpreter does its IO through a namespace-scoped Scope; the underlying router capability is internal. Dispatch owns a detached task so a swarm callback deadline stops waiting without cancelling an already committed protocol transition or its ordered effect trace.

Implementations

impl Backend

pub fn new(provider: Arc<Provider>) -> Self

Create a new backend over a provider, sharing its protocol registry.

Trait Implementations

impl SwarmCallback for Backend

fn on_inbound<'life0, 'life1, 'async_trait>( &'life0 self, payload: &'life1 MessagePayload, ) -> Pin<Box<dyn Future<Output = Result<(), CallbackError>> + Send + 'async_trait>>

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

This method is invoked when a new message is received and after handling. Will not be invoked if the message is not for this node.

fn on_validate<'life0, 'life1, 'async_trait>( &'life0 self, _payload: &'life1 MessagePayload, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Sync + Send>>> + Send + 'async_trait>>

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

This method is invoked when a new message is received and before handling.

fn on_event<'life0, 'life1, 'async_trait>( &'life0 self, _event: &'life1 SwarmEvent, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Sync + Send>>> + Send + 'async_trait>>

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

This method is invoked after the Swarm handling.