Struct MercurySocket 

pub struct MercurySocket { /* private fields */ }

Mercury WebSocket connection manager.

Implementations

impl MercurySocket

pub fn new( _ws_factory: Option<Arc<dyn Fn(String) -> Pin<Box<dyn Future<Output = Result<Box<dyn InjectedWebSocket>, Box<dyn Error + Send + Sync>>> + Send>> + Send + Sync>>, ping_interval: Duration, pong_timeout: Duration, reconnect_backoff_max: Duration, max_reconnect_attempts: u32, ) -> Self

pub async fn take_event_rx(&self) -> Option<UnboundedReceiver<MercuryEvent>>

Take the event receiver. Can only be called once.

pub async fn connect(&self, ws_url: &str, token: &str) -> Result<(), WebexError>

Connect to Mercury WebSocket.

pub async fn disconnect(&self)

Disconnect from Mercury.

pub async fn connected(&self) -> bool

Whether the WebSocket is currently connected.

pub async fn current_reconnect_attempts(&self) -> u32

Current reconnection attempt count.