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 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 handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: Message, _ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Handle an incoming message.

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 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.