Struct SPSCUnboundedConsumer 

pub struct SPSCUnboundedConsumer<T: Send, SC = NaiveRWLock<LightArc<Version<T>>>>
where
    SC: SyncCell<LightArc<Version<T>>>,
{ /* private fields */ }

The consumer of the [SPSCUnboundedQueue].

Trait Implementations

impl<T: Send, SC> Clone for SPSCUnboundedConsumer<T, SC>

where SC: SyncCell<LightArc<Version<T>>>,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Send, SC> Consumer<T> for SPSCUnboundedConsumer<T, SC>

where SC: SyncCell<LightArc<Version<T>>>,

fn capacity(&self) -> usize

Returns the capacity of the queue.

fn len(&self) -> usize

Returns the length of the queue.

fn pop_many(&self, dst: &mut [MaybeUninit<T>]) -> usize

Pops many values from the queue and returns the number of read values.

fn steal_into(&self, dst: &impl SingleProducer<T>) -> usize

Steals some values from the consumer and places them into dst. Returns the number of stolen values.

fn is_empty(&self) -> bool

Returns whether the queue is empty.

fn pop(&self) -> Option<T>

Pops a value from the queue and returns it.

impl<T: Send, SC> LockFreeConsumer<T> for SPSCUnboundedConsumer<T, SC>

where SC: SyncCell<LightArc<Version<T>>> + LockFreeSyncCell<LightArc<Version<T>>>,

fn lock_free_pop_many(&self, dst: &mut [MaybeUninit<T>]) -> (usize, bool)

Pops many values from the queue. Returns the number of popped values and whether the operation failed because it should wait.

fn lock_free_steal_into( &self, dst: &impl SingleLockFreeProducer<T>, ) -> (usize, bool)

Steals some values from the consumer and places them into dst. Returns the number of stolen values and whether the operation failed because it should wait.

fn lock_free_pop(&self) -> Result<T, LockFreePopErr>

Pops a value from the queue. On failure, returns Err(LockFreePopErr).

impl<T: Send, SC> Send for SPSCUnboundedConsumer<T, SC>

where SC: SyncCell<LightArc<Version<T>>>,

impl<T: Send, SC> SingleConsumer<T> for SPSCUnboundedConsumer<T, SC>

where SC: SyncCell<LightArc<Version<T>>>,

impl<T: Send, SC> SingleLockFreeConsumer<T> for SPSCUnboundedConsumer<T, SC>

where SC: SyncCell<LightArc<Version<T>>> + LockFreeSyncCell<LightArc<Version<T>>>,