pub fn recv_transform_publish_batch<Rx, Tx, F>(
rx: &mut Rx,
tx: &mut Tx,
input: &mut [u8],
output: &mut [u8],
on_full: OnFullV1,
wait: &mut impl WaitStrategy,
batch: usize,
transform: F,
) -> Result<bool, LaneTxError>Expand description
Receive → transform → publish, up to batch messages.
Returns Ok(true) if at least one message was processed.