Struct SubscriptionState 

pub struct SubscriptionState {
    pub latest_stream_height: Option<String>,
    pub current_filters: MessageFilters,
}

Serializable subscription state that can be persisted and restored.

This state contains all the information needed to restore a MessagesManager to its previous subscription state after a connection restart.

Fields

latest_stream_height: Option<String>

The latest stream height we’ve received Used to resume from the correct position after reconnection

current_filters: MessageFilters

Combined subscription filters accumulated over time This represents the union of all active subscriptions

Implementations

impl SubscriptionState

pub fn new() -> SubscriptionState

Create a new empty subscription state

pub fn with_filters(filters: MessageFilters) -> SubscriptionState

Create subscription state with initial filters

pub fn add_filters(&mut self, new_filters: &[Filter])

Add filters to the combined state

pub fn remove_filters(&mut self, filters_to_remove: &[Filter])

Remove filters from the combined state

pub fn set_stream_height(&mut self, height: String)

Update the latest stream height

pub fn has_active_filters(&self) -> bool

Check if we have any active filters

Trait Implementations

impl Clone for SubscriptionState

fn clone(&self) -> SubscriptionState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionState

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

Formats the value using the given formatter.

impl Default for SubscriptionState

fn default() -> SubscriptionState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SubscriptionState

fn deserialize<__D>( __deserializer: __D, ) -> Result<SubscriptionState, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SubscriptionState

fn eq(&self, other: &SubscriptionState) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for SubscriptionState

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SubscriptionState