Struct ClientManagerSync 

pub struct ClientManagerSync { /* private fields */ }

Implementations

impl ClientManagerSync

pub fn get_rt(&self) -> Arc<Runtime>

pub fn connect(&self)

Connect to the websocket server

pub fn disconnect(&self) -> Result<RealtimeClientBuilder, RecvError>

Disconnect the client Returns a preconfigured RealtimeClientBuilder for modification or reinstantiation

pub fn get_ws_tx(&self) -> Result<UnboundedSender<RealtimeMessage>, RecvError>

pub fn get_state(&self) -> Result<ClientState, RecvError>

Returns the current ClientState

pub fn get_access_token(&self) -> Result<String, RecvError>

Returns the current access token used by this client

pub fn get_access_token_arc(&self) -> Result<Arc<Mutex<String>>, RecvError>

Returns an Arc referencing the client’s internal tokio runtime

pub fn set_access_token( &self, access_token: String, ) -> Result<String, RecvError>

Modify the client’s access token This change cascades through all connected channels and sends the appropriate messages to the server

pub fn to_async(self) -> ClientManager

Unwrap the inner ClientManager. Consumes self.

Trait Implementations

impl Clone for ClientManagerSync

fn clone(&self) -> ClientManagerSync

Returns a duplicate of the value.

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

Performs copy-assignment from source.