Engine.ReactiveBanana

Network setup

allocateActuated :: MonadUnliftIO m => (UnliftIO m -> Event () -> MomentIO ()) -> ResourceT m EventNetwork

Set up a network, run it and fire the started event before returning.

allocatePaused :: MonadUnliftIO m => (UnliftIO m -> MomentIO ()) -> ResourceT m EventNetwork

Set up a network, passing a current context to the network-building function.

The network would pause when leaving resource region.

Event utilities

eventHandler :: (MonadResource m, MonadIO io) => ((a -> io ()) -> m ReleaseKey) -> ResourceT m (MomentIO (Event a))

Make an Event that can be fired by a callback registered in a current resource region.

debounce :: Eq a => a -> Event a -> MomentIO (Event a)

Filter out successive events with the same data.

The output event will be delayed by one step due to reactimate use.

reactimateDebugShow

Arguments

:: (Show a, MonadIO m, MonadReader env m, HasLogFunc env, HasCallStack)

=> (m () -> IO ())

Unlift into application

-> Event a

Event to monitor

-> MomentIO ()

Dump event contents to application debug log.

timer

Arguments

:: MonadUnliftIO m

=> Int

Timer interval in microseconds

-> ResourceT m (MomentIO (Event Double))

Deprecated: Use Engine.ReactiveBanana.Timer.every

An async process that will fire monotonic timestamp events and self-adjust for the delays induced by its handling.

Engine.Worker interface

From workers to networks

observe :: MonadUnliftIO m => Var a -> ResourceT m (MomentIO (Event a))

Convert Var updates into events.

From networks to workers

pushWorkerInput :: HasInput var => var -> Event (GetInput var) -> MomentIO ()

Set worker input to event contents.

pushWorkerInputJust :: HasInput var => var -> Event (Maybe (GetInput var)) -> MomentIO ()

Set worker input to event contents, if present.

pushWorkerOutput :: HasOutput var => var -> Event (GetOutput var) -> MomentIO ()

Set worker output to event contents.

pushWorkerOutputJust :: HasOutput var => var -> Event (Maybe (GetOutput var)) -> MomentIO ()

Set worker output to event contents, if present.