Trait SubscriptionManager 

pub trait SubscriptionManager:
    Send
    + Sync
    + Debug {
    // Required methods
    fn start_notify<'life0, 'async_trait>(
        &'life0 self,
        id: 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,
        id: ListenerId,
        scope: Scope,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;

    // Provided method
    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 { ... }
}

A manager of subscriptions (see Scope) for registered listeners

Required Methods

fn start_notify<'life0, 'async_trait>( &'life0 self, id: 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, id: ListenerId, scope: Scope, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Provided Methods

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,

Implementors

impl SubscriptionManager for SubscriptionManagerMock

impl<N> SubscriptionManager for Root<N>

where N: Notification,

impl<N, C> SubscriptionManager for Notifier<N, C>

where N: Notification, C: Connection<Notification = N>,