Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Subscription manager with capacity limits.

Implementations

impl SubscriptionManager

pub fn new(max_subscriptions: usize) -> SubscriptionManager

Creates a new subscription manager with the specified maximum capacity.

pub fn with_default_capacity() -> SubscriptionManager

Creates a new subscription manager with the default maximum capacity (100).

pub fn max_subscriptions(&self) -> usize

Returns the maximum number of subscriptions allowed.

pub fn try_add( &self, key: String, subscription: Subscription, ) -> Result<(), Error>

Attempts to add a subscription.

pub fn remove(&self, key: &str) -> Option<Subscription>

Removes a subscription by key.

pub fn count(&self) -> usize

Returns the current number of active subscriptions.

pub fn remaining_capacity(&self) -> usize

Returns the remaining capacity for new subscriptions.

pub fn contains(&self, key: &str) -> bool

Checks if a subscription exists for the given key.

pub fn get(&self, key: &str) -> Option<Ref<'_, String, Subscription>>

Returns a reference to the subscription for the given key, if it exists.

pub fn clear(&self)

Clears all subscriptions.

pub fn iter(&self) -> impl Iterator<Item = RefMulti<'_, String, Subscription>>

Returns an iterator over all subscriptions.

pub fn collect_subscriptions(&self) -> Vec<Subscription>

Collects all subscriptions into a vector.

pub fn is_full(&self) -> bool

Checks if the manager is at full capacity.

pub fn is_empty(&self) -> bool

Checks if the manager has no subscriptions.

Trait Implementations

impl Debug for SubscriptionManager

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

Formats the value using the given formatter.

impl Default for SubscriptionManager

fn default() -> SubscriptionManager

Returns the “default value” for a type.