Struct eventstore::ReadAllEvents

pub struct ReadAllEvents { /* fields omitted */ }

Like ReadStreamEvents but specialized to system stream '$all'.

Implementations

impl ReadAllEvents

pub fn forward(self) -> Self

Asks the command to read forward (toward the end of the stream). That's the default behavior.

pub fn backward(self) -> Self

Asks the command to read backward (toward the begining of the stream).

pub fn credentials(self, value: Credentials) -> Self

Performs the command with the given credentials.

pub fn start_from(self, start: Position) -> Self

Starts the read ot the given event number. By default, it starts at types::Position::start.

pub fn start_from_beginning(self) -> Self

Starts the read from the beginning of the stream. It also set the read direction to Forward.

pub fn start_from_end_of_stream(self) -> Self

Starts the read from the end of the stream. It also set the read direction to Backward.

pub fn resolve_link_tos(self, tos: LinkTos) -> Self

When using projections, you can have links placed into another stream. If you set true, the server will resolve those links and will return the event that the link points to. Default: NoResolution.

pub async fn execute(
    self,
    count: u64
) -> Result<Box<dyn Stream<Item = Result<ResolvedEvent>> + Send + Unpin>>

Sends asynchronously the read command to the server.

pub async fn read_through(
    self
) -> Result<Box<dyn Stream<Item = Result<ResolvedEvent>> + Send + Unpin>>

Reads all the events of $all stream.