Struct WsServer

pub struct WsServer { /* private fields */ }

WebSocket server for phone PWA connections.

Implementations

impl WsServer

pub fn new( config: WsServerConfig, producer: NetBufferProducer, command_rx: Receiver<ServerCommand>, ) -> Self

Create a new WebSocket server.

Arguments

• config - Server configuration
• producer - Buffer producer for sending messages to audio thread
• command_rx - Channel for receiving commands from main thread

pub fn command_channel() -> (Sender<ServerCommand>, Receiver<ServerCommand>)

Create a command channel pair for communicating with the server.

pub fn clock(&self) -> Arc<ClockSync>

Get the clock synchronization instance.

pub fn subscribe(&self) -> Receiver<ServerMessage>

Get a handle to subscribe to state broadcasts.

pub async fn run(self) -> Result<()>

Run the WebSocket server.

This method runs until a shutdown command is received or an error occurs.