Struct Producer 

pub struct Producer { /* private fields */ }

Producer endpoint of the MPSC ring buffer.

This type is Clone - multiple producers can write concurrently. Use try_claim to claim space for writing.

Implementations

impl Producer

pub fn try_claim(&mut self, len: usize) -> Result<WriteClaim<'_>, TryClaimError>

Attempts to claim space for a record with the given payload length.

Returns a WriteClaim that can be written to and then committed.

Errors

• TryClaimError::ZeroLength if len is zero
• TryClaimError::Full if the buffer is full

Safety Contract

len must not exceed 0x7FFF_FFFF (2GB - 1). This is checked with debug_assert! only.

pub fn capacity(&self) -> usize

Returns the capacity of the buffer.

pub fn is_disconnected(&self) -> bool

Returns true if the consumer has been dropped.

Trait Implementations

impl Clone for Producer

fn clone(&self) -> Producer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Producer

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

Formats the value using the given formatter.

impl Send for Producer