Copyright | FOAM team <http://foam.space> 2018 |
---|---|
License | Apache-2.0 |
Maintainer | mail@akru.me |
Stability | experimental |
Portability | unportable |
Safe Haskell | None |
Language | Haskell2010 |
Contract event filters.
Synopsis
- event :: (DecodeEvent i ni e, JsonRpc m) => Filter e -> (e -> ReaderT Change m EventAction) -> m ()
- eventMany :: (DecodeEvent i ni e, JsonRpc m) => Filter e -> Integer -> (e -> ReaderT Change m EventAction) -> m ()
- eventNoFilter :: (DecodeEvent i ni e, JsonRpc m) => Filter e -> (e -> ReaderT Change m EventAction) -> m ()
- eventManyNoFilter :: (DecodeEvent i ni e, JsonRpc m) => Filter e -> Integer -> (e -> ReaderT Change m EventAction) -> m ()
Documentation
event :: (DecodeEvent i ni e, JsonRpc m) => Filter e -> (e -> ReaderT Change m EventAction) -> m () Source #
Run one block at a time.
eventMany :: (DecodeEvent i ni e, JsonRpc m) => Filter e -> Integer -> (e -> ReaderT Change m EventAction) -> m () Source #
eventMany
take s a filter, a window size, and a handler.
It runs the handler over the results of eventLogs
results using
reduceEventStream
. If no TerminateEvent
action is thrown and
the toBlock is not yet reached, it then transitions to polling.
eventNoFilter :: (DecodeEvent i ni e, JsonRpc m) => Filter e -> (e -> ReaderT Change m EventAction) -> m () Source #
eventManyNoFilter :: (DecodeEvent i ni e, JsonRpc m) => Filter e -> Integer -> (e -> ReaderT Change m EventAction) -> m () Source #