Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Manages subscription state and recovery

Implementations

impl SubscriptionManager

pub fn new(connection_manager: Weak<ConnectionManager>) -> Self

Creates a new subscription manager

pub fn set_connection_manager( &self, _connection_manager: Weak<ConnectionManager>, )

Sets the connection manager reference

pub async fn add_subscription( &self, subscription_id: usize, subscription: SubscriptionState, )

Adds a subscription to be managed

pub async fn remove_subscription( &self, subscription_id: usize, ) -> Option<SubscriptionState>

Removes a subscription from management

pub async fn get_subscription( &self, subscription_id: usize, ) -> Option<SubscriptionState>

Gets a subscription by ID

pub async fn get_all_subscriptions(&self) -> HashMap<usize, SubscriptionState>

Gets all managed subscriptions

pub async fn mark_all_disconnected(&self)

Marks all subscriptions as disconnected

pub async fn preserve_subscriptions(&self) -> Result<(), SubscriptionError>

Preserves subscription state during disconnection

pub async fn reestablish_subscriptions( &self, client: &Arc<Mutex<LightstreamerClient>>, ) -> Result<(), ReconnectionError>

Reestablishes all subscriptions after reconnection

pub async fn get_statistics(&self) -> SubscriptionStatistics

Gets subscription statistics

pub async fn clear_failed_subscriptions(&self) -> usize

Clears all failed subscriptions

Trait Implementations

impl Debug for SubscriptionManager

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

Formats the value using the given formatter.