Control.CUtils.FChan

Functional channels | A channel data type which allows consumers to hold references to different points in a stream at the same time. Elements of a channel are kept alive only so long as there are references pointing before those elements. And producers on a channel are kept alive only so long as there are consumers.

Documentation

data Chan t

data DoneReadingException

Thrown by the writer function when the garbage collector detects that no one will read it.

Constructors

DoneReadingException

Instances

Show DoneReadingException

Exception DoneReadingException

Typeable * DoneReadingException

takeChan :: Chan t -> IO (t, Chan t)

Take the first element from a channel, and a channel representing the remainder of the output.

newChan :: IO (t -> IO (), Chan t)

Create a new channel. The first return value is a function that can be used to add values to the channel. The second return value is the channel itself.

makeConsumer :: Chan b -> IO (IO b, IO (Chan b))

The first return value is a thunk that returns values from the channel successively, starting from the position of the parameter channel. The second thunk can be used to retrieve the position of the channel after all the reads made using the first thunk.