Struct AckCommitted 

pub struct AckCommitted { /* private fields */ }

Continuous acknowledgement advanced the cursor.

Implementations

impl AckCommitted

pub const fn new(request: ParticipantAckEnvelope) -> Self

Constructs a committed acknowledgement whose cursor is the requested cumulative boundary.

pub const fn request(&self) -> &ParticipantAckEnvelope

Request envelope.

pub const fn current_cursor(&self) -> DeliverySeq

Resulting committed cursor, equal to request.through_seq.

Trait Implementations

impl Clone for AckCommitted

fn clone(&self) -> AckCommitted

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AckCommitted

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

Formats the value using the given formatter.

impl Eq for AckCommitted

impl PartialEq for AckCommitted

fn eq(&self, other: &AckCommitted) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for AckCommitted