Copyright	(c) The University of Glasgow 2001
License	BSD-style (see the file libraries/base/LICENSE)
Maintainer	[email protected]
Stability	experimental
Portability	non-portable (concurrency)
Safe Haskell	Trustworthy
Language	Haskell2010

The Chan type

data Chan a Source

Chan is an abstract type representing an unbounded FIFO channel.

Operations

newChan :: IO (Chan a) Source

Build and returns a new instance of Chan.

writeChan :: Chan a -> a -> IO () Source

Write a value to a Chan.

readChan :: Chan a -> IO a Source

Read the next value from the Chan. Blocks when the channel is empty. Since the read end of a channel is an MVar, this operation inherits fairness guarantees of MVars (e.g. threads blocked in this operation are woken up in FIFO order).

Throws BlockedIndefinitelyOnMVar when the channel is empty and no other thread holds a reference to the channel.

dupChan :: Chan a -> IO (Chan a) Source

Duplicate a Chan: 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.

(Note that a duplicated channel is not equal to its original. So: fmap (c /=) $ dupChan c returns True for all c.)

unGetChan :: Chan a -> a -> IO () Source

Put a data item back onto a channel, where it will be the next item read.

isEmptyChan :: Chan a -> IO Bool Source

Returns True if the supplied Chan is empty.

Stream interface

getChanContents :: Chan a -> IO [a] Source

Return a lazy list representing the contents of the supplied Chan, much like hGetContents.

writeList2Chan :: Chan a -> [a] -> IO () Source

Write an entire list of items to a Chan.