pub fn auto_ack<S: StreamExt + Stream<Item = Delivery>>(
stream: S,
) -> impl Stream<Item = (AutoAck, Vec<u8>)>Expand description
Map consumer stream into automatically ack stream. The AutoAck object can still be used to release the ack, and manually ack it or not ack it.