publish_with_policy

byteor_pipeline_kernel::step

Function publish_with_policy 

Source 
pub fn publish_with_policy<Tx: LaneTx>(
    tx: &mut Tx,
    msg: &[u8],
    on_full: OnFullV1,
    wait: &mut impl WaitStrategy,
) -> Result<(), LaneTxError>
Expand description

Publish a message to a lane, applying on_full backpressure semantics with an explicit wait strategy.

  • On success, resets wait.
  • On Full + OnFullV1::Block, calls wait.wait() and retries.
  • On Full + OnFullV1::Drop, returns Ok(()) (drop the message).