Struct concurrency_traits::AsyncCustomQueue

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, 

pub fn new(
    queue: Q,
    message_queue: MQ,
    thread_spawner: impl ThreadSpawner
) -> Self

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, 

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

Appends to the queue asynchronously.

fn pop_async(&self) -> Self::PopFuture

Receives from the queue asynchronously.

impl<Q, MQ> Clone for AsyncCustomQueue<Q, MQ>

fn clone(&self) -> Self

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Q: Debug, MQ: Debug> Debug for AsyncCustomQueue<Q, MQ>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.