eventstore-1.4.0: EventStore TCP Client

Copyright(C) 2018 Yorick Laupa
License(see the file LICENSE)
MaintainerYorick Laupa <yo.eight@gmail.com>
Stabilityexperimental
Portabilitynon-portable
Safe HaskellNone
LanguageHaskell2010

Database.EventStore.Streaming

Description

 
Synopsis

Documentation

data Fetch t Source #

Constructors

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

newtype ReadResultHandler Source #

Constructors

ReadResultHandler 

Fields

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.

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.