Struct WsClient 

pub struct WsClient { /* private fields */ }

Active worker-side WS session. Cheap to construct, expensive to drop (closes the socket gracefully).

Implementations

impl WsClient

pub fn split(self) -> (WsSender, WsReceiver)

Split the client into a cheap-to-clone WsSender and a single-owner WsReceiver. Used by the runtime so heartbeat, log-shipper, and engine-dispatch tasks can all push frames concurrently while a dedicated task drains the receive side.

impl WsClient

pub async fn send(&mut self, frame: &WorkerInbound) -> WsResult<()>

Send a typed inbound frame as a JSON text frame.

pub async fn recv(&mut self) -> WsResult<Option<WorkerOutbound>>

Receive the next typed outbound frame. Returns Ok(None) on a clean close (no error frame), Err on auth or transport failures, or Ok(Some(frame)) for normal traffic. Pings and other control frames are swallowed silently.

pub async fn close(&mut self, code: u16, reason: &str) -> WsResult<()>

Best-effort graceful close. Idempotent.

Trait Implementations

impl Debug for WsClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.