Portability | non-portable (requires STM) |
---|---|
Stability | experimental |
Maintainer | Peter Robinson <robinson@ecs.tuwien.ac.at> |
Corresponds to Control.Concurrent.STM.TChan
- data TChan a
- newTChan :: MonadAdvSTM m => m (TChan a)
- newTChanIO :: IO (TChan a)
- readTChan :: MonadAdvSTM m => TChan a -> m a
- writeTChan :: MonadAdvSTM m => TChan a -> a -> m ()
- dupTChan :: MonadAdvSTM m => TChan a -> m (TChan a)
- unGetTChan :: MonadAdvSTM m => TChan a -> a -> m ()
- isEmptyTChan :: MonadAdvSTM m => TChan a -> m Bool
Documentation
newTChan :: MonadAdvSTM m => m (TChan a)Source
Build and returns a new instance of TChan
newTChanIO :: IO (TChan a)Source
readTChan :: MonadAdvSTM m => TChan a -> m aSource
Read the next value from the TChan
.
writeTChan :: MonadAdvSTM m => TChan a -> a -> m ()Source
Write a value to a TChan
.
dupTChan :: MonadAdvSTM m => TChan a -> m (TChan a)Source
Duplicate a TChan
: the duplicate channel begins empty, but data written to
either channel from then on will be available from both. Hence this creates
a kind of broadcast channel, where data written by anyone is seen by
everyone else.
unGetTChan :: MonadAdvSTM m => TChan a -> a -> m ()Source
Put a data item back onto a channel, where it will be the next item read.
isEmptyTChan :: MonadAdvSTM m => TChan a -> m BoolSource