Box.Queue

STM Queues, based originally on pipes-concurrency

Documentation

data Queue a

Queue specifies how messages are queued

Constructors

Unbounded

Bounded Int

Single

Latest a

Newest Int

New

queueL :: MonadConc m => Queue a -> (Committer m a -> m l) -> (Emitter m a -> m r) -> m l

Create an unbounded queue, returning the result from the Committer action.

>>> queueL New (\c -> glue c <$|> qList [1..3]) toListM

queueR :: MonadConc m => Queue a -> (Committer m a -> m l) -> (Emitter m a -> m r) -> m r

Create an unbounded queue, returning the result from the Emitter action.

>>> queueR New (\c -> glue c <$|> qList [1..3]) toListM
[3]

queue :: MonadConc m => Queue a -> (Committer m a -> m l) -> (Emitter m a -> m r) -> m (l, r)

Create an unbounded queue, returning both results.

>>> queue Unbounded (\c -> glue c <$|> qList [1..3]) toListM
((),[1,2,3])

fromAction :: MonadConc m => (Box m a b -> m r) -> CoBox m b a

Turn a box action into a box continuation

emitQ :: MonadConc m => Queue a -> (Committer m a -> m r) -> CoEmitter m a

Hook a committer action to a queue, creating an emitter continuation.

commitQ :: MonadConc m => Queue a -> (Emitter m a -> m r) -> CoCommitter m a

Hook a committer action to a queue, creating an emitter continuation.