Control.Concurrent.STM.TChan.Extra

Documentation

type DiffNanosec = Int

debounceStatic :: DiffNanosec -> TChan a -> IO (TChan a, Async ())

Note: In this model, even though we are using STM, a write to the outgoing channel does not imply a transactional write to the output channel; they are separated between a run IO layer, which means we cannot atomically debounce or interleave the system (because that depends on real-world time).

throttleStatic :: DiffNanosec -> TChan a -> IO (TChan a, Async ())

intersperseStatic :: DiffNanosec -> IO a -> TChan a -> IO (TChan a, Async (), Async ())