Struct StreamQuery 

pub struct StreamQuery<ID: EventId, E: Event + Clone> { /* private fields */ }

Represents a query for filtering event streams.

A StreamQuery is used to define filters and constraints for querying event streams. It allows you to specify a filter to narrow down the events of interest and an origin to determine the starting point of the query within the event stream.

Implementations

impl<ID: EventId, E: Event + Clone> StreamQuery<ID, E>

pub fn filters(&self) -> &[StreamFilter<ID, E>]

Returns the filter associated with the stream query, if any.

pub fn cast<U>(&self) -> StreamQuery<ID, U>

where E: Event + Into<U>, U: Event + Clone,

Casts the stream query to a different event type.

pub fn union<U, O>(&self, other: &StreamQuery<ID, O>) -> StreamQuery<ID, U>

where E: Event + Into<U>, U: Event + Clone, O: Event + Into<U> + Clone,

Unions two stream queries into a single query.

pub fn change_origin(self, origin: ID) -> Self

Changes the origin of the stream query.

The origin determines the starting point of the query within the event stream.

pub fn exclude_events(self, excluded_events: &'static [&'static str]) -> Self

Excludes the specified events from the stream query.

The excluded events are not included in the query results.

pub fn matches(&self, event: &PersistedEvent<ID, E>) -> bool

Checks if the stream query matches the given event.

pub fn matches_event(&self, event: &str) -> bool

Trait Implementations

impl<ID: Clone + EventId, E: Clone + Event + Clone> Clone for StreamQuery<ID, E>

fn clone(&self) -> StreamQuery<ID, E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<ID: Debug + EventId, E: Debug + Event + Clone> Debug for StreamQuery<ID, E>

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

Formats the value using the given formatter.

impl<ID, S, E: Event + Clone> From<&S> for StreamQuery<ID, E>

where S: StateQuery<Event = E>, ID: EventId,

fn from(state: &S) -> Self

Converts to this type from the input type.

impl<ID: EventId, E: Event + Clone + PartialEq> PartialEq for StreamQuery<ID, E>

fn eq(&self, other: &Self) -> 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.