eventstore-1.4.1: EventStore TCP Client

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 where
- StreamDeleted :: StreamName -> ReadError EventNumber
- ReadError :: Maybe Text -> ReadError t
- AccessDenied :: StreamId t -> ReadError t
- NoStream :: ReadError EventNumber
data Fetch t
- = FetchError !(ReadError t)
- | Fetch !(Slice t)
newtype ReadResultHandler = ReadResultHandler {
- runReadResultHandler :: forall t. StreamId t -> BatchResult t -> Fetch 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 ()
defaultReadResultHandler :: ReadResultHandler
onRegularStream :: (ReadResult EventNumber (Slice EventNumber) -> Fetch EventNumber) -> ReadResultHandler
readThrough :: Connection -> ReadResultHandler -> ReadDirection -> StreamId t -> ResolveLink -> t -> Maybe Int32 -> Maybe Credentials -> Stream (Of ResolvedEvent) (ExceptT (ReadError t) IO) ()

Documentation

data ReadError t where Source #

Constructors

StreamDeleted :: StreamName -> ReadError EventNumber
ReadError :: Maybe Text -> ReadError t
AccessDenied :: StreamId t -> ReadError t
NoStream :: ReadError EventNumber

Instances

Show (ReadError t) Source #
Instance details 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) Source #
Instance details Defined in Database.EventStore.Streaming Methods toException :: ReadError t -> SomeException # fromException :: SomeException -> Maybe (ReadError t) # displayException :: ReadError t -> String #

data Fetch t Source #

Constructors

FetchError !(ReadError t)
Fetch !(Slice t)

newtype ReadResultHandler Source #

Constructors

ReadResultHandler
Fields runReadResultHandler :: forall t. StreamId t -> BatchResult t -> Fetch t

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.

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

Throws an exception in case ExceptT is a Left.

defaultReadResultHandler :: ReadResultHandler Source #

onRegularStream :: (ReadResult EventNumber (Slice EventNumber) -> Fetch EventNumber) -> ReadResultHandler Source #

readThrough :: Connection -> ReadResultHandler -> ReadDirection -> 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.