Struct ReceiveSet

pub struct ReceiveSet<T: Send> {
    receivers: Mutex<Vec<Receiver<T>>>,
}

A set of connected Receivers.

Any receiver that gets disconnected is automatically removed from the set.

Fields

receivers: Mutex<Vec<Receiver<T>>>

Implementations

impl<T: Send> ReceiveSet<T>

pub fn new(receivers: Vec<Receiver<T>>) -> Self

pub fn add(&self, r: Receiver<T>)

pub fn remove(&self, source: &SmartChannelSource)

Disconnect from any channel with the given source.

pub fn retain(&self, f: impl FnMut(&Receiver<T>) -> bool)

pub fn clear(&self)

Remove all receivers.

pub fn sources(&self) -> Vec<Arc<SmartChannelSource>>

List of connected receiver sources.

This gets culled after calling one of the recv methods.

pub fn is_connected(&self) -> bool

Any connected receivers?

This gets updated after calling one of the recv methods.

pub fn is_empty(&self) -> bool

No connected receivers?

This gets updated after calling one of the recv methods.

pub fn latency_nanos(&self) -> u64

Maximum latency among all receivers (or 0, if none).

pub fn queue_len(&self) -> usize

Sum queue length of all receivers.

pub fn recv(&self) -> Result<SmartMessage<T>, RecvError>

Blocks until a message is ready to be received, or we are empty.

pub fn try_recv(&self) -> Option<(Arc<SmartChannelSource>, SmartMessage<T>)>

Returns immediately if there is nothing to receive.

pub fn recv_timeout( &self, timeout: Duration, ) -> Option<(Arc<SmartChannelSource>, SmartMessage<T>)>

Trait Implementations

impl<T: Send> Default for ReceiveSet<T>

fn default() -> Self

Returns the “default value” for a type.