STM.Scatter

Documentation

data Scatter a

A Scatter is a single source that can broadcast messages to any number of subscribers.

scatter :: MonadBase IO m => m (Scatter a)

Creates a new Scatter.

scatterMsg :: MonadBase IO m => Scatter a -> a -> m ()

Post a message to a Scatter to all the subscribed Gathers.

data Gather a

A Gather receives copies of all messages posted to the Scatter it was derived from.

gather :: MonadBase IO m => Getter (Scatter a) (m (Gather a))

Create a new Gather from a given Scatter.

gatherMsg :: MonadBase IO m => Gather a -> m a

Read a message posted to a Gather by a Scatter.