Struct CatchUpSubscription 

pub struct CatchUpSubscription { /* private fields */ }

Implementations

impl CatchUpSubscription

pub fn new( checkpoint: SubscriptionCheckpoint, batch_size: usize, ) -> Result<Self>

Creates an explicitly acknowledged catch-up subscription.

Errors

Rejects a zero batch size.

pub const fn checkpoint(&self) -> SubscriptionCheckpoint

pub fn poll<E, S>(&mut self, store: &S) -> Vec<StoredEvent<E>>

where E: Clone, S: EventStore<E>,

Returns the next batch without advancing the durable checkpoint.

pub fn acknowledge(&mut self, global_position: u64) -> Result<()>

Acknowledges all delivered events through an inclusive position.

Errors

Rejects acknowledgements beyond the last delivered event or behind the current checkpoint.

Trait Implementations

impl Clone for CatchUpSubscription

fn clone(&self) -> CatchUpSubscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CatchUpSubscription

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

Formats the value using the given formatter.

impl Eq for CatchUpSubscription

impl PartialEq for CatchUpSubscription

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for CatchUpSubscription