Struct sage_broker::Subs

pub struct Subs { /* fields omitted */ }

The list of all subcriptions registered by the broker

Implementations

impl Subs

pub fn new(cache: Arc<Cache>) -> Self

Builds a new Subscription DB with the given cache

pub fn len(&self) -> usize

The number of subscriptions

pub fn add(
    &mut self,
    topic: Topic,
    options: SubscriptionOptions,
    identifier: Option<u32>
) -> bool

Add a subscription for the given filter to the given session Returns true if it replaces an existing one

pub fn has_filter(&self, topic: &Topic) -> bool

Check wether the given session is subscribed to the given filter

pub fn matches(&self, name: &Topic) -> bool

Check wether the given topic name matches any filter within this subs

Trait Implementations

impl Clone for Subs

fn clone(&self) -> Subs

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Subs

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

Formats the value using the given formatter.