Struct Queue 

pub struct Queue<T>(Arc<Inner<T>>);

Tuple Fields

0: Arc<Inner<T>>

Implementations

impl<T> Queue<T>

pub fn new() -> Self

pub fn enqueue(&self, s: Slot, i: MsgId, val: T)

pub fn try_dequeue(&self) -> Option<(Slot, MsgId, T)>

pub async fn dequeue(&self) -> (Slot, MsgId, T)

pub fn gc(&self, s: Slot)

pub fn len(&self) -> usize

Trait Implementations

impl<T> Clone for Queue<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for Queue<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for Queue<T>

fn default() -> Self

Returns the “default value” for a type.