Struct whisk::Queue

pub struct Queue<T = (), U: ?Sized = ()> { /* private fields */ }

A Queue can send messages to itself, and can be shared between threads and tasks.

Implemented as a multi-producer/multi-consumer queue of size 1.

Implementations

impl<T> Queue<T>

pub const fn new() -> Self

Create a new queue.

impl<T, U> Queue<T, U>

pub const fn with(user_data: U) -> Self

Create a new queue with associated data.

impl<T, U: ?Sized> Queue<T, U>

pub async fn send(&self, message: T)

Send a message on this queue.

pub async fn recv(&self) -> T

Receive a message from this queue.

Trait Implementations

impl<T, U: ?Sized> Debug for Queue<T, U>

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

Formats the value using the given formatter.

impl<T, U: ?Sized + Default> Default for Queue<T, U>

fn default() -> Self

Returns the “default value” for a type.

impl<T, U: ?Sized> Deref for Queue<T, U>

type Target = U

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.