Struct tokio::sync::broadcast::Waiter

struct Waiter {
    queued: AtomicBool,
    waker: Option<Waker>,
    pointers: Pointers<Waiter>,
    _p: PhantomPinned,
}

An entry in the wait queue.

Fields

queued: AtomicBool

True if queued.

waker: Option<Waker>

Task waiting on the broadcast channel.

pointers: Pointers<Waiter>

Intrusive linked-list pointers.

_p: PhantomPinned

Should not be Unpin.

Implementations

impl Waiter

fn new() -> Self

impl Waiter

unsafe fn addr_of_pointers(me: NonNull<Self>) -> NonNull<Pointers<Waiter>>

Trait Implementations

impl Link for Waiter

Safety

Waiter is forced to be !Unpin.

type Handle = NonNull<Waiter>

Handle to the list entry.

type Target = Waiter

Node type.

fn as_raw(handle: &NonNull<Waiter>) -> NonNull<Waiter>

Convert the handle to a raw pointer without consuming the handle.

unsafe fn from_raw(ptr: NonNull<Waiter>) -> NonNull<Waiter>

Convert the raw pointer to a handle

unsafe fn pointers(target: NonNull<Waiter>) -> NonNull<Pointers<Waiter>>

Return the pointers for a node