Struct embedded_async_helpers::ssq::Consumer

pub struct Consumer<'a, T> { /* private fields */ }

Read handle to a single slot queue.

Implementations

impl<'a, T> Consumer<'a, T>

pub fn dequeue(&mut self) -> Option<T>

Try reading a value from the queue.

pub fn is_empty(&self) -> bool

Check if there is a value in the queue.

Trait Implementations

impl<'a, T> Send for Consumer<'a, T>

Safety: We gurarantee the safety using an AtomicBool to gate the read of the UnsafeCell.