Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Implementations

impl ConnectionManager

pub async fn new( url: String, config: ConnectionConfig, frame_tx: Sender<Frame>, ) -> Result<Self, HyperStackError>

pub async fn state(&self) -> ConnectionState

pub async fn last_error(&self) -> Option<Arc<HyperStackError>>

pub async fn last_socket_issue(&self) -> Option<SocketIssue>

pub fn subscribe_socket_issues(&self) -> Receiver<SocketIssue>

pub async fn ensure_subscription(&self, view: &str, key: Option<&str>)

pub async fn ensure_subscription_with_opts( &self, view: &str, key: Option<&str>, opts: SubscriptionOptions, )

pub async fn subscribe(&self, sub: Subscription)

pub async fn unsubscribe(&self, unsub: Unsubscription)

pub async fn disconnect(&self)

Trait Implementations

impl Clone for ConnectionManager

fn clone(&self) -> ConnectionManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.