Struct QueueImpl 

pub struct QueueImpl<T, OutputError, KeyGen>(/* private fields */)
where
    T: Dequeue,
    OutputError: From<T::Error>,
    KeyGen: KeyFor<Key = T::Key, Value = T::Value>;

Mailbox implementation based on Dequeue.

Generic parameter KeyGen presents key generation for given values.

Trait Implementations

impl<T, OutputError, KeyGen> Counted for QueueImpl<T, OutputError, KeyGen>

where T: Dequeue + Counted, OutputError: From<T::Error>, KeyGen: KeyFor<Key = T::Key, Value = T::Value>,

type Length = <T as Counted>::Length

Returning length type.

fn len() -> Self::Length

Returns current Self’s amount of elements as Length type.

fn is_empty() -> bool

Returns bool, defining if Self doesn’t contain elements.

impl<T, OutputError, KeyGen> IterableMap<Result<<T as Dequeue>::Value, OutputError>> for QueueImpl<T, OutputError, KeyGen>

where T: Dequeue + IterableMap<Result<T::Value, T::Error>>, OutputError: From<T::Error>, KeyGen: KeyFor<Key = T::Key, Value = T::Value>,

type DrainIter = QueueDrainIter<T, OutputError>

Removal iterator type.

type Iter = QueueIter<T, OutputError>

Getting iterator type.

fn drain() -> Self::DrainIter

Creates the removal iterator over map Items.

fn iter() -> Self::Iter

Creates the getting iterator over map Items.

impl<T, OutputError, KeyGen> Queue for QueueImpl<T, OutputError, KeyGen>

where T: Dequeue, OutputError: From<T::Error>, T::Error: DequeueError, KeyGen: KeyFor<Key = T::Key, Value = T::Value>,

type Value = <T as Dequeue>::Value

Stored values type.

type Error = <T as Dequeue>::Error

Inner error type of queue storing algorithm.

type OutputError = OutputError

Output error type of the queue.

fn dequeue() -> Result<Option<Self::Value>, Self::OutputError>

Removes and returns message from the beginning of the queue, if present,

fn mutate_values<F: FnMut(Self::Value) -> Self::Value>(f: F)

Mutates all values in queue with given function.

fn queue(value: Self::Value) -> Result<(), Self::OutputError>

Inserts given value at the end of the queue.

fn clear()

Removes all values from queue.

fn requeue(value: Self::Value) -> Result<(), Self::OutputError>

Inserts given value at the beginning of the queue.