Eventful.ReadModel.Class

Documentation

data ReadModel model serialized m

Constructors

ReadModel

Fields

• readModelModel :: model
• readModelLatestAppliedSequence :: model -> m SequenceNumber
• readModelHandleEvents :: model -> [GlobalStreamEvent serialized] -> m ()

runPollingReadModel :: (MonadIO m, Monad mstore) => ReadModel model serialized m -> GlobalEventStoreReader mstore serialized -> (forall a. mstore a -> m a) -> PollingPeriodSeconds -> m ()