Struct ShmEventsMpscTx 

pub struct ShmEventsMpscTx { /* private fields */ }

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

Implementations

impl ShmEventsMpscTx

pub fn publish_with<F, E>(&self, f: F) -> Result<(), PublishWithError<E>>

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

Publish by writing directly into the backing slot buffer.

pub fn publish_slot(&self, slot: EventsSlot) -> Result<(), LaneTxError>

Publish a previously-received slot (slot forwarding).

Trait Implementations

impl LaneTx for ShmEventsMpscTx

fn publish(&mut self, bytes: &[u8]) -> Result<(), LaneTxError>

Publish the message.

impl LaneTxSlot<EventsSlot> for ShmEventsMpscTx

fn publish_slot( &mut self, slot: EventsSlot, ) -> Result<(), LaneTxSlotError<EventsSlot>>

Publish an owned slot.

impl LaneTxWith for ShmEventsMpscTx

fn publish_with<F>(&mut self, f: F) -> Result<(), LaneTxError>

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

Publish a message by writing it into a provided slot buffer.

impl LaneTxWithResult for ShmEventsMpscTx

fn publish_with_result<F, E>(&mut self, f: F) -> Result<(), LaneTxWithError<E>>

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

Publish a message by writing it into a provided slot buffer.