Struct Writer

pub struct Writer { /* private fields */ }

Wraps RingBuffer and allows to publish messages. Only single writer should be present at any time.

Implementations

impl Writer

pub const fn claim(&mut self, len: usize, fin: bool) -> Claim<'_>

Claim part of the underlying RingBuffer for publication. The fin flag is used to indicate final message fragment.

Panics

When aligned message length is greater than the MTU.

pub const fn claim_with_user_defined( &mut self, len: usize, fin: bool, user_defined: u32, ) -> Claim<'_>

Claim part of the underlying RingBuffer for publication. The fin flag is used to indicate final message fragment. This method also accepts user_defined value that will be attached to the message frame header.

Panics

When aligned message length is greater than the MTU.

pub const fn continuation(&mut self, len: usize, fin: bool) -> Claim<'_>

Claim part of the underlying RingBuffer for continuation frame publication also passing fin value to indicate final message fragment.

Panics

When aligned message length is greater than the MTU.

pub const fn heartbeat(&mut self) -> Claim<'_>

Claim part of the underlying RingBuffer for heartbeat frame publication (zero payload, no user defined field and no fragmentation) This operation will always succeed.

pub const fn mtu(&self) -> usize

Get maximum permissible unaligned payload length that can be accepted by the buffer. It is calculated as min(capacity / 2 - size_of::<FrameHeader>(), MAX_PAYLOAD_LEN) where MAX_PAYLOAD_LEN is (1 << 31) - 1.

Trait Implementations

impl Debug for Writer

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

Formats the value using the given formatter.

impl From<RingBuffer> for Writer

fn from(ring: RingBuffer) -> Self

Converts to this type from the input type.