Struct re_ws_comms::server::ReceiveSetBroadcaster

struct ReceiveSetBroadcaster {
    inner: Arc<Mutex<ReceiveSetBroadcasterInnerState>>,
    shutdown_on_next_recv: Arc<AtomicBool>,
}

Broadcasts messages to all connected clients and stores a history of messages to resend to new clients.

This starts a thread which will close when the underlying ReceiveSet gets a quit message or looses all its connections.

Fields

inner: Arc<Mutex<ReceiveSetBroadcasterInnerState>>

shutdown_on_next_recv: Arc<AtomicBool>

Implementations

impl ReceiveSetBroadcaster

pub fn new(log_rx: ReceiveSet<LogMsg>, server_memory_limit: MemoryLimit) -> Self

fn broadcast_thread_func( log_rx: &ReceiveSet<LogMsg>, inner: &Mutex<ReceiveSetBroadcasterInnerState>, shutdown: &AtomicBool )

pub fn add_client(&self, client: WebSocket<TcpStream>)

Adds a websocket client to the broadcaster and replies all message history so far to it.

Trait Implementations

impl Drop for ReceiveSetBroadcaster

fn drop(&mut self)

Executes the destructor for this type.