Struct glommio::channels::spsc_queue::Producer

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

A handle to the queue which allows adding values onto the buffer

Implementations

impl<T> Producer<T>

pub fn try_push(&self, v: T) -> Option<T>

Attempt to push a value onto the buffer.

This method does not block. If the queue is not full, the value will be added to the queue and the method will return None, signifying success. If the queue is full, this method will return Some(v)``, where v` is your original value.

pub fn disconnect(&self) -> bool

Disconnects the producer, signaling to the consumer that no new values are going to be produced.

Returns the buffer status before the disconnect

pub fn consumer_disconnected(&self) -> bool

Whether the associated consumer is disconnected.

pub fn free_space(&self) -> usize

Returns the available space in the queue

This value represents the number of items that can be pushed onto the queue before it becomes full.

Trait Implementations

impl<T> Clone for Producer<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 Producer<T>

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

Formats the value using the given formatter.

impl<T: Send> Send for Producer<T>