box-0.2.0: boxes

Safe Haskell	None
Language	Haskell2010

Box.Broadcast

Description

This module is experimental and may not work.

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 {
- unFunnel :: TVar m (Emitter m a)
}
funnel :: MonadSTM stm => stm (Funneler stm a, Emitter stm a)
widen :: MonadConc m => Funneler (STM m) a -> Cont m (Committer (STM m) a)

Documentation

newtype Broadcaster m a Source #

a broadcaster

Constructors

Broadcaster
Fields unBroadcast :: TVar m (Committer m a)

broadcast :: MonadSTM stm => stm (Broadcaster stm a, Committer stm a) Source #

create a (broadcaster, committer)

subscribe :: MonadConc m => Broadcaster (STM m) a -> Cont m (Emitter (STM m) a) Source #

subscribe to a broadcaster

newtype Funneler m a Source #

a funneler

Constructors

Funneler
Fields unFunnel :: TVar m (Emitter m a)

funnel :: MonadSTM stm => stm (Funneler stm a, Emitter stm a) Source #

create a (funneler, emitter)

widen :: MonadConc m => Funneler (STM m) a -> Cont m (Committer (STM m) a) Source #

widen to a funneler