Struct NativeSocket 

pub struct NativeSocket { /* private fields */ }

Send + Sync handle for a managed client running on a dedicated thread.

Implementations

impl NativeSocket

pub fn spawn( endpoint: impl Into<String>, config: ConnectionConfig, ) -> Result<Self, NativeRuntimeError>

Starts a worker with static connection configuration and default options.

pub fn spawn_with_options( endpoint: impl Into<String>, config: ConnectionConfig, options: NativeOptions, ) -> Result<Self, NativeRuntimeError>

Starts a worker with static connection configuration and custom options.

pub fn spawn_with_loader( endpoint: impl Into<String>, config_loader: NativeConnectionConfigLoader, options: NativeOptions, ) -> Result<Self, NativeRuntimeError>

Starts a worker with per-attempt connection configuration.

pub fn status(&self) -> SocketStatus

Returns the latest managed socket status.

pub fn events(&self) -> NativeSocketEvents

Creates an independent bounded socket event receiver.

pub fn status_changes(&self) -> NativeSocketStatusChanges

Creates a receiver for subsequent socket status changes.

pub fn worker_status(&self) -> NativeWorkerStatus

Returns the latest worker-thread status.

pub fn worker_status_changes(&self) -> NativeWorkerStatusChanges

Creates a receiver for subsequent worker-thread status changes.

pub async fn connect(&self) -> Result<(), NativeRuntimeError>

Enables connection attempts.

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

Sends a heartbeat with the configured call timeout and returns its RTT.

pub async fn ping_with_timeout( &self, timeout: Duration, ) -> Result<Duration, NativeRuntimeError>

Sends a heartbeat with an explicit timeout and returns its RTT.

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

Disables automatic reconnection and closes the active transport.

pub async fn disconnect_with( &self, code: u16, reason: impl Into<String>, ) -> Result<(), NativeRuntimeError>

Disconnects with an explicit WebSocket close code and reason.

pub async fn channel( &self, topic: impl Into<String>, payload: Value, ) -> Result<NativeChannel, NativeRuntimeError>

Registers a channel with a static join payload.

pub async fn channel_with_loader( &self, topic: impl Into<String>, payload_loader: NativeJoinPayloadLoader, ) -> Result<NativeChannel, NativeRuntimeError>

Registers a channel with a payload loader evaluated for every join.

pub async fn shutdown(&self) -> Result<(), NativeRuntimeError>

Permanently stops and joins the dedicated worker.

pub fn join_worker(&self) -> Result<(), NativeRuntimeError>

Blocks the current thread until the worker exits.

Async callers should normally use NativeSocket::shutdown instead.

Trait Implementations

impl Clone for NativeSocket

fn clone(&self) -> NativeSocket

Returns a duplicate of the value.

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

Performs copy-assignment from source.