Struct Queue

pub struct Queue<Q> { /* private fields */ }

Implementations

impl<Q> Queue<Q>

pub fn new<N: Into<Cow<'static, str>>>(inner: Q, name: N) -> Self

Trait Implementations

impl<Q: Debug> Debug for Queue<Q>

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

Formats the value using the given formatter.

impl<Q: Default> Default for Queue<Q>

fn default() -> Self

Returns the “default value” for a type.

impl<Q> Deref for Queue<Q>

type Target = Q

The resulting type after dereferencing.

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

Dereferences the value.

impl<Q> DerefMut for Queue<Q>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<T, Q> Queue<T> for Queue<Q>

where Q: Queue<T>,

fn push_lazy( &mut self, value: &mut dyn Pushable<T>, ) -> Result<Option<T>, PushError>

fn push_with_notify( &mut self, value: &mut dyn Pushable<T>, cx: &mut Context<'_>, ) -> Result<Option<T>, PushError>

fn pop(&mut self) -> Result<T, PopError>

fn pop_with_notify(&mut self, cx: &mut Context<'_>) -> Result<T, PopError>

fn close(&mut self) -> Result<(), CloseError>

fn is_closed(&self) -> bool

fn is_empty(&self) -> bool

fn is_full(&self) -> bool

fn len(&self) -> usize

fn capacity(&self) -> Option<usize>

fn push(&mut self, value: T) -> Result<Option<T>, (PushError, T)>

Pushes value into the queue while returning it as an error if the operation fails

fn check_push(&self) -> Result<(), PushError>