Rebase.Control.Concurrent.STM.TQueue

TQueue is an abstract type representing an unbounded FIFO channel.

Efficiently read the entire contents of a TQueue into a list. This function never retries.

Returns True if the supplied TQueue is empty.

Build and returns a new instance of TQueue

IO version of newTQueue. This is useful for creating top-level TQueues using unsafePerformIO, because using atomically inside unsafePerformIO isn't possible.

Get the next value from the TQueue without removing it, retrying if the channel is empty.

Read the next value from the TQueue.

A version of peekTQueue which does not retry. Instead it returns Nothing if no value is available.

A version of readTQueue which does not retry. Instead it returns Nothing if no value is available.

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

Write a value to a TQueue.