Database.EventStore.Streaming

Documentation

data ReadError t

Constructors

StreamDeleted !StreamName

ReadError !(Maybe Text)

AccessDenied !(StreamId t)

Instances

Show (ReadError t)

Defined in Database.EventStore.Streaming

Methods

showsPrec :: Int -> ReadError t -> ShowS

show :: ReadError t -> String

showList :: [ReadError t] -> ShowS

(Show t, Typeable t) => Exception (ReadError t)

Defined in Database.EventStore.Streaming

Methods

toException :: ReadError t -> SomeException

fromException :: SomeException -> Maybe (ReadError t)

displayException :: ReadError t -> String

readThroughForward :: Connection -> StreamId t -> ResolveLink -> t -> Maybe Int32 -> Maybe Credentials -> Stream (Of ResolvedEvent) (ExceptT (ReadError t) IO) ()

Returns an iterator able to consume a stream entirely. When reading forward, the iterator ends when the last stream's event is reached.

readThroughBackward :: Connection -> StreamId t -> ResolveLink -> t -> Maybe Int32 -> Maybe Credentials -> Stream (Of ResolvedEvent) (ExceptT (ReadError t) IO) ()

Returns an iterator able to consume a stream entirely. When reading backward, the iterator ends when the first stream's event is reached.

throwOnError :: (Show t, Typeable t) => Stream (Of a) (ExceptT (ReadError t) IO) () -> Stream (Of a) IO ()

Throws an exception in case ExceptT is a Left.