Struct Delivery 

pub struct Delivery<T> { /* private fields */ }

A received item paired with the handle that confirms or returns it.

Processing is complete only when the AckHandle taken from into_parts is acked; until then a durable backend may redeliver after a crash. Dropping a delivery without acking leaves it unconfirmed (a durable backend redelivers it later).

Implementations

impl<T> Delivery<T>

pub fn new(item: T, handle: Box<dyn AckHandle>) -> Self

Build a delivery from an item and its backend ack handle.

pub fn into_parts(self) -> (T, Box<dyn AckHandle>)

Split into the item and its ack handle, so the item can be processed and the handle acked once the work is durably done.

pub async fn nack(self) -> Result<()>

Return the item to the queue for redelivery (processing failed).

Trait Implementations

impl<T: Debug> Debug for Delivery<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.