Struct ChangeBatch 

pub struct ChangeBatch { /* private fields */ }

One durable batch from an anchored backend change stream.

Implementations

impl ChangeBatch

pub const fn new( changes: Vec<CloudChange>, next_cursor: ChangeCursor, has_more: bool, ) -> Self

Creates a change batch. The cursor becomes active only after effects are durably replayable.

pub fn changes(&self) -> &[CloudChange]

Returns changes in backend-defined application order.

pub const fn next_cursor(&self) -> &ChangeCursor

Returns the checkpoint following this batch.

pub const fn has_more(&self) -> bool

Returns whether another batch is immediately available.

pub fn into_parts(self) -> (Vec<CloudChange>, ChangeCursor, bool)

Consumes the batch and returns its changes, next cursor, and continuation flag.

Trait Implementations

impl Clone for ChangeBatch

fn clone(&self) -> ChangeBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeBatch

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

Formats the value using the given formatter.

impl PartialEq for ChangeBatch

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ChangeBatch

impl StructuralPartialEq for ChangeBatch