Struct EventPage 

pub struct EventPage {
    pub events: Vec<StoredEvent>,
    pub next_cursor: EventCursor,
}

One page of EventJournalReader::read_from.

next_cursor is where the following call must resume. It is the sequence of the last event in events, or the cursor that was asked for when the page is empty, so a consumer can store it unconditionally and never has to reason about the empty case.

Fields

events: Vec<StoredEvent>

The events, in sequence order, at most the requested limit.

next_cursor: EventCursor

Where to resume. Never goes backwards.

Implementations

impl EventPage

pub fn new(events: Vec<StoredEvent>, asked: EventCursor) -> Self

A page holding events, resuming after the last of them or at asked when there are none.

pub fn is_empty(&self) -> bool

Returns true when the page carried no event, which is how a consumer learns it has caught up.

Trait Implementations

impl Clone for EventPage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventPage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventPage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for EventPage

impl PartialEq for EventPage

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for EventPage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for EventPage