EventSource.Store.Stub

This module exposes an implementation of Store for testing purpose. This implementation is threadsafe.

Documentation

data Stream

Holds stream state data.

Constructors

Stream

Fields

• streamNextNumber :: EventNumber
• streamEvents :: Seq SavedEvent

data StubStore

Instances

Store StubStore

Methods

appendEvents :: (EncodeEvent a, MonadIO m) => StubStore -> StreamName -> ExpectedVersion -> [a] -> m (Async EventNumber)

readBatch :: MonadIO m => StubStore -> StreamName -> Batch -> m (Async (ReadStatus Slice))

subscribe :: MonadIO m => StubStore -> StreamName -> m Subscription

newStub :: IO StubStore

Creates a new stub event store.

streams :: StubStore -> IO (Map StreamName Stream)

Returns current StubStore streams state.

subscriptionIds :: StubStore -> StreamName -> IO [SubscriptionId]

Returns all subscriptions a stream has.

lastStreamEvent :: StubStore -> StreamName -> IO (Maybe SavedEvent)

Returns the last event of stream.