Struct async_ach_mpmc::Mpmc

pub struct Mpmc<T, const N: usize, const MP: usize, const MC: usize> { /* private fields */ }

Implementations

impl<T, const N: usize, const MP: usize, const MC: usize> Mpmc<T, N, MP, MC>

pub const fn new() -> Self

pub const fn sender(&self) -> Sender<'_, T, N, MP, MC>

pub const fn recver(&self) -> Receiver<'_, T, N, MP, MC>

Methods from Deref<Target = Ring<T, N, MP, MC>>

pub fn try_push(&self, val: T) -> Result<(), Error<T>>

Appends an element to the back of the Ring.

Returns Err if the Ring is full or in critical section.

pub fn push(&self, val: T) -> Push<'_, T, N, MP, MC>

Appends an element to the back of the Ring.

pub fn try_pop(&self) -> Result<T, Error<()>>

Removes the first element and returns it.

Returns Err if the Ring is empty or in critical section.

pub fn pop(&self) -> Pop<'_, T, N, MP, MC>

Removes the first element and returns it.

Trait Implementations

impl<T, const N: usize, const MP: usize, const MC: usize> Deref for Mpmc<T, N, MP, MC>

type Target = Ring<T, N, MP, MC>

The resulting type after dereferencing.

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

Dereferences the value.