| Safe Haskell | Safe |
|---|---|
| Language | Haskell2010 |
Control.Concurrent.STM.TChan.Typed.Extra
- type DiffNanosec = Int
- debounceStatic :: DiffNanosec -> TChanRW Read a -> IO (TChanRW Write a, Async ())
- throttleStatic :: DiffNanosec -> TChanRW Read a -> IO (TChanRW Write a, Async ())
- intersperseStatic :: DiffNanosec -> IO a -> TChanRW Read a -> IO (TChanRW Write a, Async (), Async ())
Documentation
type DiffNanosec = Int Source #
debounceStatic :: DiffNanosec -> TChanRW Read a -> IO (TChanRW Write a, Async ()) Source #
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 -> TChanRW Read a -> IO (TChanRW Write a, Async ()) Source #