Rebase.Control.Concurrent.STM.TBQueue

TBQueue is an abstract type representing a bounded FIFO channel.

The maximum number of elements the queue can hold.

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

Returns True if the supplied TBQueue is empty.

Returns True if the supplied TBQueue is full.

Return the length of a TBQueue.

Builds and returns a new instance of TBQueue.

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

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

Read the next value from the TBQueue.

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

A version of readTBQueue 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. Blocks if the queue is full.

Write a value to a TBQueue; blocks if the queue is full.