Trait concurrency_traits::AsyncPrependQueue

pub trait AsyncPrependQueue: AsyncQueue {
    type PushBackFuture: Future<Output = ()>;
    fn push_front_async(&self, value: Self::AsyncItem) -> Self::PushBackFuture;
}

An async queue that can be prepended (items placed in front)

Associated Types

type PushBackFuture: Future<Output = ()>

The future returned by prepend_async

Loading content...

Required methods

fn push_front_async(&self, value: Self::AsyncItem) -> Self::PushBackFuture

Adds to the front of the queue asynchronously

Loading content...

Implementors

impl<Q, MQ> AsyncPrependQueue for AsyncCustomDoubleEndedQueue<Q, MQ> where
    Q: DoubleEndedQueue + Send + Sync + 'static,
    MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static, 

type PushBackFuture = CompleteFuture

fn push_front_async(&self, value: Self::AsyncItem) -> Self::PushBackFuture

impl<Q, MQ> AsyncPrependQueue for AsyncCustomPrependQueue<Q, MQ> where
    Q: PrependQueue + Send + Sync + 'static,
    MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static, 

type PushBackFuture = CompleteFuture

fn push_front_async(&self, value: Self::AsyncItem) -> Self::PushBackFuture

impl<T: ?Sized> AsyncPrependQueue for T where
    T: Deref,
    T::Target: AsyncPrependQueue, 

type PushBackFuture = <T::Target as AsyncPrependQueue>::PushBackFuture

fn push_front_async(&self, value: Self::AsyncItem) -> Self::PushBackFuture

Loading content...