Struct CollabClient 

pub struct CollabClient { /* private fields */ }

Collaboration client

Implementations

impl CollabClient

pub async fn connect(config: ClientConfig) -> Result<Self>

Create a new client and connect to server

pub async fn on_workspace_update<F>(&self, callback: F)

where F: Fn(ChangeEvent) + Send + Sync + 'static,

Subscribe to workspace updates

Arguments

• callback - Function to call when workspace changes occur

pub async fn on_state_change<F>(&self, callback: F)

where F: Fn(ConnectionState) + Send + Sync + 'static,

Subscribe to connection state changes

Arguments

• callback - Function to call when connection state changes

pub async fn subscribe_to_workspace(&self, workspace_id: &str) -> Result<()>

Subscribe to a workspace

pub async fn unsubscribe_from_workspace(&self, workspace_id: &str) -> Result<()>

Unsubscribe from a workspace

pub async fn request_state( &self, workspace_id: &str, version: i64, ) -> Result<()>

Request state for a workspace

pub async fn ping(&self) -> Result<()>

Send ping (heartbeat)

pub async fn state(&self) -> ConnectionState

Get connection state

pub async fn queued_message_count(&self) -> usize

Get queued message count

pub async fn reconnect_count(&self) -> u32

Get reconnect attempt count

pub async fn disconnect(&self) -> Result<()>

Disconnect from server

Trait Implementations

impl Drop for CollabClient

fn drop(&mut self)

Executes the destructor for this type.