Struct ManyToOneRingBuffer

pub struct ManyToOneRingBuffer { /* private fields */ }

Implementations

impl ManyToOneRingBuffer

pub fn new(buffer: AtomicBuffer) -> Result<Self, RingBufferError>

pub fn write( &self, cmd: AeronCommand, src_buffer: AtomicBuffer, src_index: Index, length: Index, ) -> Result<(), RingBufferError>

pub fn read<F: FnMut(AeronCommand, AtomicBuffer)>( &self, handler: F, msg_count_limit: i32, ) -> i32

Read from the ring buffer until either wrap-around or msg_count_max messages have been processed. Returns the number of messages processed.

pub fn read_all<F: FnMut(AeronCommand, AtomicBuffer)>(&self, handler: F) -> i32

pub fn capacity(&self) -> Index

pub fn max_msg_len(&self) -> Index

pub fn next_correlation_id(&self) -> i64

pub fn set_consumer_heartbeat_time(&self, time: i64)

pub fn consumer_heartbeat_time(&self) -> i64

pub fn size(&self) -> Index

pub fn unblock(&self) -> bool

Trait Implementations

impl Debug for ManyToOneRingBuffer

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

Formats the value using the given formatter.

impl Send for ManyToOneRingBuffer

impl Sync for ManyToOneRingBuffer