Struct EventSubscriber

pub struct EventSubscriber<Id, Event> { /* private fields */ }

Redis backend implementation for eventually::EventSubscriber trait.

Trait Implementations

impl<Id, Event> EventSubscriber for EventSubscriber<Id, Event>

where Id: TryFrom<String> + Eq + Send + Sync, <Id as TryFrom<String>>::Error: Error + Send + Sync + 'static, for<'de> Event: Send + Sync + Deserialize<'de>,

type SourceId = Id

Type of the Source id, typically an AggregateId.

type Event = Event

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

type Error = SubscriberError

Possible errors returned when receiving events from the notification channel.

fn subscribe_all( &self, ) -> BoxFuture<'_, SubscriberResult<SubscriberEventStream<'_, Self>>>

Subscribes to all new events persisted in the EventStore, from the moment of calling this function, in the future.