Trait Subscriber

pub trait Subscriber: Send + Sync {
    // Required methods
    fn subscribe(
        &mut self,
        pattern: TopicPattern,
        handler: Box<dyn MessageHandler>,
    ) -> Result<(), NerveError>;
    fn unsubscribe(&mut self, pattern: &TopicPattern) -> Result<(), NerveError>;
    fn unsubscribe_all(&mut self) -> Result<(), NerveError>;
    fn subscription_count(&self) -> usize;
}

Subscriber interface

Required Methods

fn subscribe( &mut self, pattern: TopicPattern, handler: Box<dyn MessageHandler>, ) -> Result<(), NerveError>

Subscribe to a topic pattern

fn unsubscribe(&mut self, pattern: &TopicPattern) -> Result<(), NerveError>

Unsubscribe from a topic pattern

fn unsubscribe_all(&mut self) -> Result<(), NerveError>

Unsubscribe from all topics

fn subscription_count(&self) -> usize

Get subscription count

Implementations on Foreign Types

impl Subscriber for SimplePubSub

fn subscribe( &mut self, pattern: TopicPattern, handler: Box<dyn MessageHandler>, ) -> Result<(), NerveError>

fn unsubscribe(&mut self, pattern: &TopicPattern) -> Result<(), NerveError>

fn unsubscribe_all(&mut self) -> Result<(), NerveError>

fn subscription_count(&self) -> usize

Implementors

impl Subscriber for SimpleSubscriber