Module multiplexed 

Multiplexed client mode (TCP/TLS/Unix and WS/WSS). A single message connection is shared across all calls and subscriptions. A background task splits reader from writer.

Enums

NewMsg 🔒

Constants

OUTBOUND_BUFFER_SIZE 🔒

Capacity of the outbound queue feeding the writer task. Small because each in-flight call already has its own response channel, so this only buffers bursts between caller and writer.

Functions

background_loop 🔒

build_backend_state 🔒

build_byte_backend 🔒

Build the multiplexed backend by connecting over a byte stream (TCP, TLS, or Unix) and framing it.

build_ws_backend 🔒

Build the multiplexed backend by connecting over a WebSocket.

connect_byte 🔒

connect_ws 🔒

handle_mux_msg 🔒

run_io_loop 🔒

send_request 🔒

start_io_loop 🔒

Spawn the reader/writer task that drives the multiplexed wire.