Struct glommio::channels::spsc_queue::Consumer

pub struct Consumer<T> { /* fields omitted */ }

A handle to the queue which allows consuming values from the buffer

Implementations

impl<T> Consumer<T>

pub fn disconnect(&self) -> bool

Disconnects the consumer, signaling to the producer that no new values are going to be consumed. After this is done, any attempt on the producer to try_push should fail

Returns the buffer status before the disconnect

pub fn producer_disconnected(&self) -> bool

Whether the associated producer is disconnected.

pub fn try_pop(&self) -> Option<T>

Attempt to pop a value off the queue.

This method does not block. If the queue is empty, the method will return None. If there is a value available, the method will return Some(v), where v is the value being popped off the queue.

Trait Implementations

impl<T> Clone for Consumer<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for Consumer<T>

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

Formats the value using the given formatter.

impl<T: Send> Send for Consumer<T>