[−][src]Struct eventstore::commands::ReadStreamEvents
A command that reads several events from a stream. It can read events forward or backward.
Methods
impl ReadStreamEvents
[src]
pub fn forward(self) -> Self
[src]
Asks the command to read forward (toward the end of the stream). That's the default behavior.
pub fn backward(self) -> Self
[src]
Asks the command to read backward (toward the begining of the stream).
pub fn credentials(self, value: Credentials) -> Self
[src]
Performs the command with the given credentials.
pub fn set_credentials(self, creds: Option<Credentials>) -> Self
[src]
Performs the command with the given credentials.
pub fn max_count(self, max_count: i32) -> Self
[src]
Max batch size.
pub fn start_from(self, start: i64) -> Self
[src]
Starts the read at the given event number. By default, it starts at 0.
pub fn start_from_beginning(self) -> Self
[src]
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
[src]
Starts the read from the end of the stream. It also set the read
direction to Backward
.
pub fn require_master(self, require_master: bool) -> Self
[src]
Asks the server receiving the command to be the master of the cluster
in order to perform the write. Default: false
.
pub fn resolve_link_tos(self, tos: LinkTos) -> Self
[src]
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
) -> Result<ReadStreamStatus<StreamSlice>, OperationError>
[src]
self
) -> Result<ReadStreamStatus<StreamSlice>, OperationError>
Sends asynchronously the read command to the server.
pub fn iterate_over_batch(
self
) -> Pin<Box<dyn Stream<Item = Result<Vec<ResolvedEvent>, OperationError>> + Send>>
[src]
self
) -> Pin<Box<dyn Stream<Item = Result<Vec<ResolvedEvent>, OperationError>> + Send>>
Returns a Stream
that consumes a stream entirely. For example, if
the direction is Forward
, it ends when the last stream event is reached.
However, if the direction is Backward
, the iterator ends when the
first event is reached. All the configuration is pass to the iterator
(link resolution, require master, starting point, batch size, …etc). Each
element corresponds to a page with a length <= max_count
.
pub fn iterate_over(
self
) -> impl Stream<Item = Result<ResolvedEvent, OperationError>> + Send + Unpin
[src]
self
) -> impl Stream<Item = Result<ResolvedEvent, OperationError>> + Send + Unpin
Returns a Stream
that consumes a stream entirely. For example, if
the direction is Forward
, it ends when the last stream event is reached.
However, if the direction is Backward
, the iterator ends when the
first event is reached. All the configuration is pass to the iterator
(link resolution, require master, starting point, batch size, …etc).
Auto Trait Implementations
impl !RefUnwindSafe for ReadStreamEvents
impl Send for ReadStreamEvents
impl Sync for ReadStreamEvents
impl Unpin for ReadStreamEvents
impl !UnwindSafe for ReadStreamEvents
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoRequest<T> for T
[src]
fn into_request(self) -> Request<T>
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,