| Copyright | (C) 2018 Yorick Laupa |
|---|---|
| License | (see the file LICENSE) |
| Maintainer | Yorick Laupa <yo.eight@gmail.com> |
| Stability | experimental |
| Portability | non-portable |
| Safe Haskell | None |
| Language | Haskell2010 |
Database.EventStore.Streaming
Description
Synopsis
- data ReadError t
- = StreamDeleted !StreamName
- | ReadError !(Maybe Text)
- | AccessDenied !(StreamId t)
- readThroughForward :: Connection -> StreamId t -> ResolveLink -> t -> Maybe Int32 -> Maybe Credentials -> Stream (Of ResolvedEvent) (ExceptT (ReadError t) IO) ()
- readThroughBackward :: Connection -> StreamId t -> ResolveLink -> t -> Maybe Int32 -> Maybe Credentials -> Stream (Of ResolvedEvent) (ExceptT (ReadError t) IO) ()
- throwOnError :: (Show t, Typeable t) => Stream (Of a) (ExceptT (ReadError t) IO) () -> Stream (Of a) IO ()
Documentation
Constructors
| StreamDeleted !StreamName | |
| ReadError !(Maybe Text) | |
| AccessDenied !(StreamId t) |
Instances
| Show (ReadError t) Source # | |
| (Show t, Typeable t) => Exception (ReadError t) Source # | |
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) () Source #
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) () Source #
Returns an iterator able to consume a stream entirely. When reading backward, the iterator ends when the first stream's event is reached.