Struct Transient 

pub struct Transient<Store, Subscriber> { /* private fields */ }

Subscription type which gets deleted once the process using it gets terminated.

Useful for in-memory or one-off Projections.

Implementations

impl<Store, Subscriber> Transient<Store, Subscriber>

pub fn new(store: Store, subscriber: Subscriber) -> Self

Creates a new Subscription using the specified EventStore and EventSubscriber to create the SubscriptionStream from.

pub fn from(self, sequence_number: u32) -> Self

Specifies the sequence number of the Event the SubscriptionStream should start from when calling run.

Trait Implementations

impl<Store, Subscriber> Subscription for Transient<Store, Subscriber>

where Store: EventStore + Send + Sync, Subscriber: EventSubscriber<SourceId = <Store as EventStore>::SourceId, Event = <Store as EventStore>::Event> + Send + Sync, <Store as EventStore>::SourceId: Send + Sync, <Store as EventStore>::Event: Send + Sync, <Store as EventStore>::Error: StdError + Send + Sync + 'static, <Subscriber as EventSubscriber>::Error: StdError + Send + Sync + 'static,

type SourceId = <Store as EventStore>::SourceId

Type of the Source id, typically an AggregateId.

type Event = <Store as EventStore>::Event

Event type stored in the EventStore, typically an Aggregate::Event.

type Error = Error

Possible errors returned when receiving events from the notification channel.

fn resume( &self, ) -> BoxFuture<'_, Result<SubscriptionStream<'_, Self>, Self::Error>>

Resumes the current state of a Subscription by returning the EventStream, starting from the last event processed by the Subscription.

fn checkpoint(&self, version: u32) -> BoxFuture<'_, Result<(), Self::Error>>

Saves the provided version (or sequence number) as the latest version processed.