Struct concurrency_traits::AsyncCustomQueue [−][src]
pub struct AsyncCustomQueue<Q, MQ> { /* fields omitted */ }
A custom async queue for turing a queue asynchronous. Creates a task for running the queue functions.
Implementations
impl<Q, MQ> AsyncCustomQueue<Q, MQ> where
Q: Queue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]
impl<Q, MQ> AsyncCustomQueue<Q, MQ> where
Q: Queue + 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::ThreadHandle), TS::SpawnError> where
TS: ThreadSpawner<()>,
[src]
queue: Q,
message_queue: MQ,
thread_spawner: TS
) -> Result<(Self, TS::ThreadHandle), TS::SpawnError> where
TS: ThreadSpawner<()>,
Creates a new AsyncCustomQueue
from a backing queue and message
queue
Trait Implementations
impl<Q, MQ> AsyncQueue for AsyncCustomQueue<Q, MQ> where
Q: Queue + Send + Sync + 'static,
MQ: Queue<Item = AsyncQueueMessage<Q::Item>> + Send + Sync + 'static,
[src]
impl<Q, MQ> AsyncQueue for AsyncCustomQueue<Q, MQ> where
Q: Queue + 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 push_async
type PopFuture = ValueFuture<Self::AsyncItem>
The future returned by pop_async
fn push_async(&self, value: Self::AsyncItem) -> Self::PushFuture
[src]
fn pop_async(&self) -> Self::PopFuture
[src]
impl<Q, MQ> Clone for AsyncCustomQueue<Q, MQ>
[src]
impl<Q, MQ> Clone for AsyncCustomQueue<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 AsyncCustomQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,
impl<Q, MQ> RefUnwindSafe for AsyncCustomQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,
impl<Q, MQ> Unpin for AsyncCustomQueue<Q, MQ>
impl<Q, MQ> Unpin for AsyncCustomQueue<Q, MQ>
impl<Q, MQ> UnwindSafe for AsyncCustomQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,
impl<Q, MQ> UnwindSafe for AsyncCustomQueue<Q, MQ> where
MQ: RefUnwindSafe,
Q: RefUnwindSafe,