Struct ManagedWsHandle 

pub struct ManagedWsHandle { /* private fields */ }

Implementations

impl ManagedWsHandle

pub fn subscribe_messages(&self) -> ManagedMessageReceiver

Messages in connection-local wire order. The first subscriber receives the since-spawn backlog; later subscribers start at subscription time. Lag returns ManagedReceiveError::Gap.

pub fn subscribe_reference_changes(&self) -> ReferenceChangeReceiver

pub fn subscribe_events(&self) -> Receiver<ManagedWsEvent>

Lifecycle events, including the since-spawn backlog for the first subscriber.

pub fn subscribe_state(&self) -> Receiver<ManagedWsState>

Subscribe to the latest lifecycle state.

pub fn state(&self) -> ManagedWsState

pub fn vault_auth(&self) -> Option<VaultAuthSuccessData>

Vault grant for the current connection, as the server saw it at auth; None on maker sessions.

pub fn subscribe_vault_auth(&self) -> Receiver<Option<VaultAuthSuccessData>>

Follow vault authentications and invalidation (None) across reconnects.

pub fn is_ready(&self) -> bool

pub fn ensure_ready(&self) -> Result<(), ManagedWsError>

pub async fn wait_until_ready(&self) -> Result<u64, WaitUntilReadyError>

Wait for authentication and recovery to finish.

pub async fn send(&self, message: ClientMessage) -> Result<(), ManagedWsError>

pub async fn send_in_epoch( &self, message: ClientMessage, connection_epoch: u64, ) -> Result<(), ManagedWsError>

Send only in the connection epoch whose recovery the caller applied. A reconnect before dequeue rejects this command instead of rebinding it.

pub fn try_send( &self, message: ClientMessage, ) -> Result<SendTicket, ManagedWsError>

pub fn try_send_in_epoch( &self, message: ClientMessage, connection_epoch: u64, ) -> Result<SendTicket, ManagedWsError>

Non-blocking Self::send_in_epoch.

pub async fn send_await( &self, message: ClientMessage, timeout_duration: Duration, ) -> Result<Arc<ServerMessage>, SendAwaitError>

pub async fn close(&self) -> Result<(), ManagedWsError>

Trait Implementations

impl Clone for ManagedWsHandle

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.