Network.Ethereum.Web3.Contract.Internal

reduceEventStream :: forall a f. Monad f => MonadRec f => Producer (Array (FilterChange a)) f BlockNumber -> (a -> ReaderT Change f EventAction) -> Process f BlockNumber

reduceEventStream takes a handler and an initial state and attempts to run the handler over the event stream. If the machine ends without a TerminateEvent result, we return the current state. Otherwise we return Nothing.

pollFilter :: forall ni i a e. DecodeEvent i ni a => FilterId -> ChainCursor -> Producer (Array (FilterChange a)) (Web3 e) BlockNumber

pollFilter takes a FilterId and a max ChainCursor and polls a filter for changes until the chainHead's BlockNumber exceeds the ChainCursor, if ever. There is a minimum delay of 1 second between polls.

logsStream :: forall a ni i e. DecodeEvent i ni a => FilterStreamState a -> Producer (Array (FilterChange a)) (Web3 e) BlockNumber

mkBlockNumber :: forall e. ChainCursor -> Web3 e BlockNumber

Coerce a 'ChainCursor' to an actual 'BlockNumber'.

class UncurryFields fields curried result | curried -> result fields where

Useful class for using records as arguments to solidity functions

Members

• uncurryFields :: Record fields -> curried -> result

Instances

• UncurryFields () (Web3 e b) (Web3 e b)
• (IsSymbol s, RowCons s a before after, RowLacks s before, UncurryFields before f b) => UncurryFields after (Tagged (SProxy s) a -> f) b