Struct async_ach_waker::list::WakerList

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

Implementations

impl<T> WakerList<T>

pub const fn new() -> Self

pub unsafe fn register(&self, waker: &mut Node<WakerEntity<T>>)

Register a waker

Safety: This function is only safe as long as node is guaranteed to get removed from the list before it gets moved or dropped.

pub fn remove(&self, waker: &mut Node<WakerEntity<T>>)

Removes a node from the LinkedList.

pub fn wake_one(&self) -> bool

Wake a waiter, and remove it.

Returns false if the list is empty.

pub fn wake_all(&self) -> usize

Wake all waiter, and remove it.

returns the number of had waked

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

Retains only the elements specified by the predicate.

In other words, remove all elements e such that f(&e) returns false. This method operates in place, visiting each element exactly once in the original order, but not preserves the order of the retained elements.