Module ws 

WebSocket server + chat-broadcast registry.

net.serve_ws(port, on_message) blocks on a TCP listener, upgrades each incoming connection to WebSocket, and runs a per-connection worker thread that polls both inbound (calls Lex’s on_message) and outbound (drains broadcasts from a channel into the socket).

chat.broadcast(room, body) looks up every connection in room and pushes body onto its outbound channel. chat.send(conn_id, body) is the same but to a single connection.

The registry is an Arc<Mutex<…>> because Lex’s immutability means shared mutable state has to live in the host runtime. Lex code stays pure: it receives an event, returns Nil, and any side effects go through chat.* which is gated by the policy.

Structs

ChatRegistry

Global chat registry. One per net.serve_ws invocation.

Functions

chat_broadcast

chat.broadcast(room, body) — looked up at runtime by the effect handler; called from inside the Lex VM.

chat_send

dial_ws

net.dial_ws(url, subprotocol, on_open, on_message) -> [net, E] Result[Unit, Str]. Blocks for the lifetime of the connection; returns Ok(()) on a clean close from the server, Err(reason) on dial failure, handshake failure, read error, or write error.

dial_ws_actor

serve_ws

serve_ws_fn

Closure-based WebSocket server. Accepts a Value::Closure as the handler.

serve_ws_fn_actor

net.serve_ws_fn_actor — binds the host from the environment.

serve_ws_fn_actor_on

The same server with the bind interface named outright (#719).

serve_ws_fn_auth

Closure-based WebSocket server with a pre-handshake auth callback. Calls auth_closure(path, headers) before completing the WS upgrade; rejects with 401 Unauthorized when the closure returns Err(msg). See serve_ws_fn for the post-handshake behaviour (identical once auth passes).

ws_bind_host

Bind a WebSocket server. Blocks; returns Unit on shutdown (the process is normally killed before that). The interface the net.serve_ws* family binds to (#719).