Struct tokio::sync::broadcast::WaitersList

struct WaitersList<'a, T> {
    list: GuardedLinkedList<Waiter, <Waiter as Link>::Target>,
    is_empty: bool,
    shared: &'a Shared<T>,
}

List used in Shared::notify_rx. It wraps a guarded linked list and gates the access to it on the Shared.tail mutex. It also empties the list on drop.

Fields

list: GuardedLinkedList<Waiter, <Waiter as Link>::Target>

is_empty: bool

shared: &'a Shared<T>

Implementations

impl<'a, T> WaitersList<'a, T>

fn new( unguarded_list: LinkedList<Waiter, <Waiter as Link>::Target>, guard: Pin<&'a Waiter>, shared: &'a Shared<T>, ) -> Self

fn pop_back_locked(&mut self, _tail: &mut Tail) -> Option<NonNull<Waiter>>

Removes the last element from the guarded list. Modifying this list requires an exclusive access to the main list in Notify.

Trait Implementations

impl<'a, T> Drop for WaitersList<'a, T>

fn drop(&mut self)

Executes the destructor for this type.