Struct SendBuffer 

pub struct SendBuffer { /* private fields */ }

A broadcast-style send buffer. The outlet pushes samples in, and each consumer (TCP client session) gets its own queue.

Implementations

impl SendBuffer

pub fn new() -> Arc<Self>

pub fn push_sample(&self, sample: Sample)

Push a sample to all consumers

pub fn push_sentinel(&self)

Wake up consumers (e.g., during shutdown)

pub fn new_consumer(&self, max_buffered: usize) -> Receiver<Option<Sample>>

Register a new consumer and return its receiver

pub fn have_consumers(&self) -> bool

Check if there are active consumers

pub fn wait_for_consumers(&self, timeout: f64) -> bool

Wait until at least one consumer is registered