Struct MpmcQueueWrapper 

pub struct MpmcQueueWrapper<T> { /* private fields */ }

Implementations

impl<T> MpmcQueueWrapper<T>

pub fn new<H: Handle<HandleInner = Self>>( max_accessors: usize, size: usize, ) -> H

pub unsafe fn push( &self, id: &mut MpmcQueueAccessorId, value: T, ) -> StartSend<T, SendError<T>>

pub unsafe fn pop(&self, id: &mut MpmcQueueAccessorId) -> Async<Option<T>>

pub unsafe fn close(&self, id: &mut MpmcQueueAccessorId)

pub unsafe fn inc_sender_count(&self)

pub unsafe fn dec_sender_count(&self, id: &mut MpmcQueueAccessorId)

pub unsafe fn inc_receiver_count(&self)

pub unsafe fn dec_receiver_count(&self, id: &mut MpmcQueueAccessorId)

Trait Implementations

impl<T: Debug> Debug for MpmcQueueWrapper<T>

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

Formats the value using the given formatter.

impl<T> HandleInner<MpmcQueueAccessorId> for MpmcQueueWrapper<T>

type IdAllocator = IndexAllocator

fn id_allocator(&self) -> &IndexAllocator

fn raise_id_limit(&mut self, new_limit: usize)

fn id_limit(&self) -> usize