Struct ShmEventsMpscRx 

pub struct ShmEventsMpscRx { /* private fields */ }

SHM-backed events-chain RX lane (MPSC) over EventsChainLayout4.

Implementations

impl ShmEventsMpscRx

pub fn try_recv_with<F, R, E>( &self, f: F, ) -> Result<Option<R>, RecvWithError<E>>

where F: FnOnce(&[u8]) -> Result<R, E>,

Receive by borrowing the slot bytes for the duration of f.

pub fn try_recv_slot(&self) -> Result<Option<EventsSlot>, Error>

Receive a message as an owned slot handle (for slot forwarding).

Trait Implementations

impl LaneRx for ShmEventsMpscRx

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

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

impl LaneRxBorrow for ShmEventsMpscRx

fn recv_with<F, R>(&mut self, f: F) -> Result<Option<R>, LaneRxError>

where F: FnOnce(&[u8]) -> R,

Receive one message and pass it to f by borrowed slice.

impl LaneRxSlot for ShmEventsMpscRx

type Slot = EventsSlot

Slot handle type.

fn try_recv_slot(&mut self) -> Result<Option<Self::Slot>, LaneRxError>

Receive one message as an owned slot.