Struct ChannelApplication 

pub struct ChannelApplication { /* private fields */ }

The Application half of event_channel: it forwards the notification callbacks onto the channel and accepts everything else with the trait defaults. Construct it only via event_channel.

Trait Implementations

impl Application for ChannelApplication

fn on_create<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

A session was created at engine start.

fn on_logon<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

The session completed a logon exchange.

fn on_logout<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

The session went offline (logout or disconnect).

fn from_admin<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, msg: &'life1 Message, session_id: &'life2 SessionId, ) -> Pin<Box<dyn Future<Output = Result<(), ApplicationError>> + Send + 'async_trait>>

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

An admin message was received and verified.

fn from_app<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, msg: &'life1 Message, session_id: &'life2 SessionId, ) -> Pin<Box<dyn Future<Output = Result<(), ApplicationError>> + Send + 'async_trait>>

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

An application message was received and verified. This is the main inbound entry point for business messages.

fn to_admin<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _msg: &'life1 mut Message, _session_id: &'life2 SessionId, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

An admin message is about to be sent; last chance to mutate it (e.g. add credentials to a Logon).

fn to_app<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _msg: &'life1 mut Message, _session_id: &'life2 SessionId, ) -> Pin<Box<dyn Future<Output = Result<(), DoNotSend>> + Send + 'async_trait>>

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

An application message is about to be sent (also called for resends, with PossDupFlag=Y). Return Err(DoNotSend) to suppress it — a resend is then gap-filled.