Struct eventstore_tcp::adapted::ReadStreamCompleted

pub struct ReadStreamCompleted<'a> {
    pub events: Vec<ResolvedIndexedEvent<'a>>,
    pub next_page: Option<EventNumber>,
    pub last_event_number: StreamVersion,
    pub end_of_stream: bool,
    pub last_commit_position: i64,
}

Successful response to a Message::ReadStreamEvents.

Fields

events: Vec<ResolvedIndexedEvent<'a>>

The actual events returned by the server. Subject to resolve_link_tos setting on the read request.

next_page: Option<EventNumber>

EventNumber for a query for the next page in the same direction, None if start has been reached when reading backwards. When reading forwards, this will never be None as new events might have appeared while receiving this response.

last_event_number: StreamVersion

Event number of the last event

end_of_stream: bool

Has the end of the stream been reached (or could more events be read immediatedly)

last_commit_position: i64

Last commit position of the last event. Not public as there is currently no type for an positive i64 (0 < x < i64). Also, not sure how to explain the use of this property.

Trait Implementations

impl<'a> Debug for ReadStreamCompleted<'a>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<'a> PartialEq for ReadStreamCompleted<'a>

fn eq(&self, __arg_0: &ReadStreamCompleted<'a>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, __arg_0: &ReadStreamCompleted<'a>) -> bool

This method tests for !=.

impl<'a> Clone for ReadStreamCompleted<'a>

fn clone(&self) -> ReadStreamCompleted<'a>

Returns a copy of the value.

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

Performs copy-assignment from source.