Struct ShmFanoutTx 

pub struct ShmFanoutTx { /* private fields */ }

SHM-backed fanout TX lane.

Implementations

impl ShmFanoutTx

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.

Trait Implementations

impl LaneTx for ShmFanoutTx

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

Publish the message.

impl LaneTxWith for ShmFanoutTx

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 ShmFanoutTx

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.