Safe Haskell | None |
---|---|
Language | Haskell2010 |
Synopsis
- newtype Broadcaster m a = Broadcaster {
- unBroadcast :: TVar m (Committer m a)
- broadcast :: MonadSTM stm => stm (Broadcaster stm a, Committer stm a)
- subscribe :: MonadConc m => Broadcaster (STM m) a -> Cont m (Emitter (STM m) a)
- newtype Funneler m a = Funneler {}
- funnel :: MonadSTM stm => stm (Funneler stm a, Emitter stm a)
- widen :: MonadConc m => Funneler (STM m) a -> Cont m (Committer (STM m) a)