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

• streamNumber :: EventNumber
• streamEvents :: Seq SavedEvent

data StubStore

Instances

Store StubStore

Defined in EventSource.Store.Stub

Methods

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

readStream :: MonadBase IO m => StubStore -> StreamName -> Batch -> Stream (Of SavedEvent) (ExceptT ReadFailure m) ()

subscribe :: MonadBase IO m => StubStore -> StreamName -> m Subscription

toStore :: StubStore -> SomeStore

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.