Control.Monad.Loops.STM

Documentation

atomLoop :: STM a -> IO ()

forever and atomically rolled into one.

forkAtomLoop :: STM a -> IO ThreadId

atomLoop with a forkIO

waitFor :: (a -> Bool) -> STM a -> STM a

retry until the given condition is true of the given value. Then return the value that satisfied the condition.

waitForTrue :: STM Bool -> STM ()

retry until the given value is True.

waitForJust :: STM (Maybe a) -> STM a

retry until the given value is Just _, returning the contained value.

waitForEvent :: (a -> Bool) -> TChan a -> STM a

waitFor a value satisfying a condition to come out of a TChan, reading and discarding everything else. Returns the winner.