Struct WsServer 

pub struct WsServer { /* private fields */ }

WebSocket server adapter that accepts inbound connections.

Listens on a TCP port and spawns a WsConn actor for each incoming WebSocket connection. Optionally serves a web UI on port + 1 for peer ID discovery.

Implementations

impl WsServer

pub fn new(config: Config) -> Self

Creates a new WebSocket server with default config.

pub fn new_with_config(config: Config, ws_config: WsServerConfig) -> Self

Creates a new WebSocket server with custom config.

Arguments

• config - Node configuration
• ws_config - WebSocket server config (port, TLS)

pub fn peer_count(&self) -> usize

Returns the current number of connected WebSocket peers.

Test-only helper to poll mesh readiness without relying on blind sleeps. The count reflects the number of WsConn actors that have completed the WebSocket handshake and registered themselves in the server’s client set.

Use

// Wait for both peers to connect before broadcasting a Put.
while ws_server.peer_count() < 2 {
    sleep(Duration::from_millis(50)).await;
}

Trait Implementations

impl Actor for WsServer

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: Arc<Message>, _ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Relays wire-format messages (Put, Get, Hi, BatchPut, Flush, RtcSignal) to all connected WebSocket clients except the sender. Internal messages (CheckQuorumTimeouts, RegisterQuorum) are never relayed — they are router-internal and would produce empty or malformed frames on the wire.

fn subscribe_to_everything(&self) -> bool

WsServer is a relay adapter — it fans out Puts to all connected WebSocket clients. Must return true so the Router adds it to server_peers and relays Put messages through it.

fn is_relay_server(&self) -> bool

WsServer is a relay server — it accepts incoming connections and fans out to individual WsConn clients. The Router always relays to WsServer (even for messages from remote peers) because the WsServer handles per-connection echo-back via msg.is_from(conn).

fn pre_start<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called once before the actor starts processing messages.

fn stopping<'life0, 'life1, 'async_trait>( &'life0 mut self, _context: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called once after the actor’s message loop exits.

fn handle_batch<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, batch: &'life1 mut Vec<Arc<Message>>, context: &'life2 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Handle a batch of messages drained from the mailbox.

fn try_clone_storage(&self) -> Option<Box<dyn Actor>>

Attempts to produce a clone of this actor for storage read/write splitting.

impl Clone for WsServer

fn clone(&self) -> WsServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.