Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Map of active subscriptions, keyed by SubscriptionId.

Implementations

impl SubscriptionManager

pub fn new() -> Self

Construct a new manager.

pub fn publish(&self, envelope: &Envelope) -> usize

Publish envelope to all subscribers; lossy under backpressure. Returns the number of subscribers the message was delivered to.

pub fn register( &self, filter: SubscriptionFilter, session_id: SessionId, ) -> (SubscriptionId, FilteredReceiver)

Register a new subscription. Returns the new id and a receiver.

pub fn unsubscribe(&self, id: &SubscriptionId) -> bool

Tear down a subscription. Returns whether it existed.

pub fn drop_session(&self, session_id: &SessionId)

Drop every subscription owned by session_id (e.g. on eviction).

pub fn len(&self) -> usize

Number of active subscriptions.

pub fn is_empty(&self) -> bool

True if no active subscriptions exist.

Trait Implementations

impl Clone for SubscriptionManager

fn clone(&self) -> SubscriptionManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionManager

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

Formats the value using the given formatter.

impl Default for SubscriptionManager

fn default() -> Self

Returns the “default value” for a type.