Struct Claim

pub struct Claim<'a> { /* private fields */ }

Represents region of the RingBuffer we can publish message to.

Implementations

impl<'a> Claim<'a>

pub const fn get_buffer(&self) -> &[u8]

Get next message payload as byte slice.

pub const fn get_buffer_mut(&mut self) -> &mut [u8]

Get next message payload as mutable byte slice.

pub const fn abort(self)

Abort the publication.

pub fn commit(self)

Commit the message thus making it visible to other consumers. If this operation is not invoked, the commit will happen automatically when Claim is dropped.

Trait Implementations

impl<'a> Debug for Claim<'a>

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

Formats the value using the given formatter.

impl Drop for Claim<'_>

fn drop(&mut self)

Executes the destructor for this type.