Struct tokio::sync::broadcast::Shared

struct Shared<T> {
    buffer: Box<[RwLock<Slot<T>>]>,
    mask: usize,
    tail: Mutex<Tail>,
    num_tx: AtomicUsize,
}

Data shared between senders and receivers.

Fields

buffer: Box<[RwLock<Slot<T>>]>

slots in the channel.

mask: usize

Mask a position -> index.

tail: Mutex<Tail>

Tail of the queue. Includes the rx wait list.

num_tx: AtomicUsize

Number of outstanding Sender handles.

Implementations

impl<T> Shared<T>

fn notify_rx<'a, 'b: 'a>(&'b self, tail: MutexGuard<'a, Tail>)