Struct ShmJournalSubscriber 

pub struct ShmJournalSubscriber { /* private fields */ }

SHM-backed journal subscriber.

Attach-only: opens/creates the mapping and exposes a subscriber handle.

Implementations

impl ShmJournalSubscriber

pub fn poll_next_len( &mut self, out: &mut [u8], ) -> Result<Option<usize>, BackingError>

Poll for the next record, copying bytes into out.

Returns Ok(None) when no record is available yet.

pub fn wait_next_len<W: WaitStrategy>( &mut self, out: &mut [u8], wait: &mut W, ) -> Result<usize, BackingError>

Spin/poll until the next record is available.

pub fn pos(&self) -> u64

Current subscriber position.

pub fn lag_bytes(&self) -> u64

Subscriber lag behind the publisher.

Trait Implementations

impl LaneRx for ShmJournalSubscriber

fn recv(&mut self, buf: &mut [u8]) -> Option<usize>

Receive one message into buf, returning the number of bytes written.