Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Manages all subscriptions using a segment-level trie.

Implementations

impl SubscriptionManager

pub fn new() -> Self

pub fn add(&self, sub: Subscription)

Add a subscription

pub fn remove(&self, session_id: &SessionId, id: u32) -> Option<Subscription>

Remove a subscription

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

Remove all subscriptions for a session

pub fn find_subscribers( &self, address: &str, signal_type: Option<SignalType>, ) -> Vec<SessionId>

Find all sessions subscribed to an address

pub fn len(&self) -> usize

Get subscription count

pub fn is_empty(&self) -> bool

Check if empty

Trait Implementations

impl Default for SubscriptionManager

fn default() -> Self

Returns the “default value” for a type.