Struct BroadcastReceiver 

pub struct BroadcastReceiver<T> { /* private fields */ }

Receiving side of a broadcast channel.

Each receiver owns a dedicated queue and therefore observes every message independently of other receivers.

Implementations

impl<T> Receiver<T>

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

Blocks until the next value arrives.

Returns mpsc::RecvError after all senders have been dropped and the queue has been drained.

pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvTimeoutError>

Blocks until the next value arrives or the timeout expires.

This is primarily useful in tests and in integration code that must avoid waiting forever for control-plane events.