Struct SubscriptionManager

pub struct SubscriptionManager { /* private fields */ }

Subscription manager

Implementations

impl SubscriptionManager

pub fn new() -> Self

Create a new subscription manager

pub fn add_subscription( &mut self, channel: String, channel_type: SubscriptionChannel, instrument: Option<String>, )

Add a subscription

pub fn add_subscription_from_channel( &mut self, channel_type: SubscriptionChannel, )

Add a subscription from channel type

pub fn remove_subscription(&mut self, channel: &str) -> Option<Subscription>

Remove a subscription

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

Get all active subscriptions

pub fn get_subscription(&self, channel: &str) -> Option<&Subscription>

Get subscription by channel

pub fn deactivate_subscription(&mut self, channel: &str)

Mark subscription as inactive

pub fn reactivate_all(&mut self)

Reactivate all subscriptions

pub fn clear(&mut self)

Clear all subscriptions

pub fn get_all_channels(&self) -> Vec<String>

Get all channel names

pub fn get_active_channels(&self) -> Vec<String>

Get active channel names

Trait Implementations

impl Debug for SubscriptionManager

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

Formats the value using the given formatter.

impl Default for SubscriptionManager

fn default() -> SubscriptionManager

Returns the “default value” for a type.