| 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 |
EventSource.Store.Internal.Iterator
Description
Synopsis
- data Batch' a = Batch' {}
- startFrom :: a -> Batch' a
- data IteratorOverState a
- data IteratorOverAction a
- iterateOver :: MonadBase IO m => IORef (IteratorOverState a) -> (Batch' a -> m (Async (ReadStatus (Slice' a)))) -> m (Maybe SavedEvent)
Documentation
Represents batch information needed to read a stream.
startFrom :: a -> Batch' a Source #
Starts a Batch from a given point. The batch size is set to default,
which is 500.
data IteratorOverState a Source #
Constructors
| IteratorOverAvailable (Slice' a) | |
| IteratorOverClosed |
data IteratorOverAction a Source #
iterateOver :: MonadBase IO m => IORef (IteratorOverState a) -> (Batch' a -> m (Async (ReadStatus (Slice' a)))) -> m (Maybe SavedEvent) Source #