Struct ClientState 

pub struct ClientState {
    pub ref_counter: u64,
    pub pending_heartbeat_ref: Option<String>,
    pub channels: Vec<Arc<RealtimeChannel>>,
    pub task_manager: TaskManager,
    pub was_manual_disconnect: bool,
    pub state_change_tx: Option<Sender<(ConnectionState, bool)>>,
}

Consolidated mutable state for RealtimeClient Using a single struct reduces lock contention

Fields

ref_counter: u64

Current ref counter for message IDs

pending_heartbeat_ref: Option<String>

Pending heartbeat ref (if any)

channels: Vec<Arc<RealtimeChannel>>

All channels managed by this client

task_manager: TaskManager

Background task manager

was_manual_disconnect: bool

Whether the disconnect was manual (prevents auto-reconnect)

state_change_tx: Option<Sender<(ConnectionState, bool)>>

Sender for state change notifications

Implementations

impl ClientState

pub fn new() -> Self

pub fn make_ref(&mut self) -> String

Generate next message reference

pub fn notify_state_change(&self, state: ConnectionState, manual: bool)

Notify state change watchers

Trait Implementations

impl Default for ClientState

fn default() -> Self

Returns the “default value” for a type.