Struct concurrency_traits::AsyncCustomDoubleEndedQueue [−][src]
pub struct AsyncCustomDoubleEndedQueue<Q, MQ> { /* fields omitted */ }
A custom async double ended queue for turing a double ended queue asynchronous. Creates a task for running the queue functions.
Implementations
impl<Q, MQ> AsyncCustomDoubleEndedQueue<Q, MQ> where
Q: DoubleEndedQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]
impl<Q, MQ> AsyncCustomDoubleEndedQueue<Q, MQ> where
Q: DoubleEndedQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]pub fn new(
queue: Q,
message_queue: MQ,
thread_spawner: impl ThreadSpawner
) -> Self
[src]
queue: Q,
message_queue: MQ,
thread_spawner: impl ThreadSpawner
) -> Self
Creates a new AsyncCustomDoubleEndedQueue
from a backing queue and
message queue
Trait Implementations
impl<Q, MQ> AsyncPrependQueue for AsyncCustomDoubleEndedQueue<Q, MQ> where
Q: DoubleEndedQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]
impl<Q, MQ> AsyncPrependQueue for AsyncCustomDoubleEndedQueue<Q, MQ> where
Q: DoubleEndedQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]type PushBackFuture = CompleteFuture
The future returned by prepend_async
fn push_front_async(&self, value: Self::AsyncItem) -> Self::PushBackFuture
[src]
impl<Q, MQ> AsyncQueue for AsyncCustomDoubleEndedQueue<Q, MQ> where
Q: DoubleEndedQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]
impl<Q, MQ> AsyncQueue for AsyncCustomDoubleEndedQueue<Q, MQ> where
Q: DoubleEndedQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]type AsyncItem = Q::Item
The type the queue holds.
type PushFuture = CompleteFuture
The future returned by append_async
type PopFuture = ValueFuture<Self::AsyncItem>
The future returned by receive_async
fn push_async(&self, value: Self::AsyncItem) -> Self::PushFuture
[src]
fn pop_async(&self) -> Self::PopFuture
[src]
impl<Q, MQ> AsyncReverseQueue for AsyncCustomDoubleEndedQueue<Q, MQ> where
Q: DoubleEndedQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]
impl<Q, MQ> AsyncReverseQueue for AsyncCustomDoubleEndedQueue<Q, MQ> where
Q: DoubleEndedQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]type PopBackFuture = ValueFuture<Self::AsyncItem>
The future returned by receive_back_async
fn pop_back_async(&self) -> Self::PopBackFuture
[src]
impl<Q, MQ> Clone for AsyncCustomDoubleEndedQueue<Q, MQ>
[src]
impl<Q, MQ> Clone for AsyncCustomDoubleEndedQueue<Q, MQ>
[src]fn clone(&self) -> Self
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
Auto Trait Implementations
impl<Q, MQ> RefUnwindSafe for AsyncCustomDoubleEndedQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,
impl<Q, MQ> RefUnwindSafe for AsyncCustomDoubleEndedQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,
impl<Q, MQ> Unpin for AsyncCustomDoubleEndedQueue<Q, MQ>
impl<Q, MQ> Unpin for AsyncCustomDoubleEndedQueue<Q, MQ>
impl<Q, MQ> UnwindSafe for AsyncCustomDoubleEndedQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,
impl<Q, MQ> UnwindSafe for AsyncCustomDoubleEndedQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,