Struct Pubsub 

pub struct Pubsub<S>
where
    S: Spec + 'static,
{ /* private fields */ }

Manager

Implementations

impl<S> Pubsub<S>

where S: Spec + 'static,

pub fn new(inner: Arc<S>) -> Self

Create a new instance

pub fn active_subscribers(&self) -> usize

Total number of active subscribers, it is not the number of active topics being subscribed

pub fn publish<E>(&self, event: E)

where E: Into<S::Event>,

Broadcast an event to all listeners

pub fn publish_now<E>(&self, event: E) -> Result<(), Error>

where E: Into<S::Event>,

Broadcast an event to all listeners right away, blocking the current thread

This function takes an Arc to the storage struct, the event_id, the kind and the vent to broadcast

pub fn subscribe_with<I>( &self, request: I, sender: &Sender<(Arc<I::SubscriptionId>, S::Event)>, receiver: Option<Receiver<(Arc<<S as Spec>::SubscriptionId>, <S as Spec>::Event)>>, ) -> Result<ActiveSubscription<S>, Error>

where I: SubscriptionRequest<Topic = <S::Event as Event>::Topic, SubscriptionId = S::SubscriptionId>,

Subscribe proving custom sender/receiver mpsc

pub fn subscribe<I>(&self, request: I) -> Result<ActiveSubscription<S>, Error>

where I: SubscriptionRequest<Topic = <S::Event as Event>::Topic, SubscriptionId = S::SubscriptionId>,

Subscribe