Struct concurrency_traits::AsyncCustomReverseQueue [−][src]
pub struct AsyncCustomReverseQueue<Q, MQ> { /* fields omitted */ }
A custom async reverse queue for turing a reverse queue asynchronous. Creates a task for running the queue functions.
Implementations
impl<Q, MQ> AsyncCustomReverseQueue<Q, MQ> where
Q: ReverseQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]
impl<Q, MQ> AsyncCustomReverseQueue<Q, MQ> where
Q: ReverseQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]pub fn new<TS>(
queue: Q,
message_queue: MQ,
thread_spawner: TS
) -> Result<(Self, TS::SpawnReturn), TS::SpawnError> where
TS: ThreadSpawner,
[src]
queue: Q,
message_queue: MQ,
thread_spawner: TS
) -> Result<(Self, TS::SpawnReturn), TS::SpawnError> where
TS: ThreadSpawner,
Creates a new AsyncCustomReverseQueue
from a backing queue and
message queue
Trait Implementations
impl<Q, MQ> AsyncQueue for AsyncCustomReverseQueue<Q, MQ> where
Q: ReverseQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]
impl<Q, MQ> AsyncQueue for AsyncCustomReverseQueue<Q, MQ> where
Q: ReverseQueue + 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 AsyncCustomReverseQueue<Q, MQ> where
Q: ReverseQueue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]
impl<Q, MQ> AsyncReverseQueue for AsyncCustomReverseQueue<Q, MQ> where
Q: ReverseQueue + 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 AsyncCustomReverseQueue<Q, MQ>
[src]
impl<Q, MQ> Clone for AsyncCustomReverseQueue<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 AsyncCustomReverseQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,
impl<Q, MQ> RefUnwindSafe for AsyncCustomReverseQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,
impl<Q, MQ> Unpin for AsyncCustomReverseQueue<Q, MQ>
impl<Q, MQ> Unpin for AsyncCustomReverseQueue<Q, MQ>
impl<Q, MQ> UnwindSafe for AsyncCustomReverseQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,
impl<Q, MQ> UnwindSafe for AsyncCustomReverseQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,