Struct Root 

pub struct Root<N>
where
    N: Notification,
{ /* private fields */ }

Root of a notification system

The Root receives new notifications via its notify function, transforms them according to its internal subscription scope and, when any, sends them through a channel.

It is a SubscriptionManager, so the notification scope can be dynamically configured according to the needs of the whole notification system.

Implementations

impl<N> Root<N>

where N: Notification,

pub fn new(sender: Sender<N>) -> Self

pub fn with_context( sender: Sender<N>, subscription_context: SubscriptionContext, ) -> Self

pub fn send(&self, notification: N) -> Result<()>

pub fn close(&self) -> bool

pub fn is_closed(&self) -> bool

pub fn has_subscription(&self, event: EventType) -> bool

Trait Implementations

impl<N> Clone for Root<N>

where N: Notification + Clone,

fn clone(&self) -> Root<N>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<N> Debug for Root<N>

where N: Notification + Debug,

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

Formats the value using the given formatter.

impl<N> Notify<N> for Root<N>

where N: Notification,

fn notify(&self, notification: N) -> Result<()>

impl<N> SubscriptionManager for Root<N>

where N: Notification,

fn start_notify<'life0, 'async_trait>( &'life0 self, __arg1: ListenerId, scope: Scope, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn stop_notify<'life0, 'async_trait>( &'life0 self, __arg1: ListenerId, scope: Scope, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn execute_subscribe_command<'life0, 'async_trait>( &'life0 self, id: ListenerId, scope: Scope, command: Command, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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