Struct async_atomic::GenericSubscriber

pub struct GenericSubscriber<T: Copy, D: Deref<Target = Atomic<T>>> { /* private fields */ }

Implementations

impl<T: Copy, D: Deref<Target = Atomic<T>>> GenericSubscriber<T, D>

pub unsafe fn new(atomic_ref: D) -> Self

Safety

Only one subscriber allowed for an atomic value.

pub fn wait<F: Fn(T) -> bool>(&mut self, pred: F) -> Wait<'_, T, F>

Asynchronously wait for predicate to be true.

pub fn wait_and_update<F: Fn(T) -> Option<T>>( &mut self, map: F ) -> WaitAndUpdate<'_, T, F>

Asynchronously wait until map returned Some(x) and then store x in atomic.

This is an asynchronous version of Atomic::fetch_update.

Trait Implementations

impl<T: Copy, D: Deref<Target = Atomic<T>>> Deref for GenericSubscriber<T, D>

type Target = D

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.