System.Logger.Internal.Queue

Documentation

class BoundedCloseableQueue q a | q -> a where

Minimal complete definition

newQueue, closeQueue, writeQueue, tryWriteQueue, readQueue

Methods

newQueue :: Natural -> IO q

closeQueue :: q -> IO ()

writeQueue :: q -> a -> IO Bool

Returns False if and only if the queue is closed. If the queue is full this function blocks.

tryWriteQueue :: q -> a -> IO (Maybe Bool)

Non-blocking version of writeQueue. Returns Nothing if the queue was full. Otherwise it returns 'Just True' if the value was successfully written and 'Just False' if the queue was closed.

readQueue :: q -> IO (Maybe a)

Returns Nothing if and only if the queue is closed. If this queue is empty this function blocks.

Instances

BoundedCloseableQueue (TBMQueue a) a

Defined in System.Logger.Internal.Queue

Methods

newQueue :: Natural -> IO (TBMQueue a)

closeQueue :: TBMQueue a -> IO ()

writeQueue :: TBMQueue a -> a -> IO Bool

tryWriteQueue :: TBMQueue a -> a -> IO (Maybe Bool)

readQueue :: TBMQueue a -> IO (Maybe a)

BoundedCloseableQueue (TBMChan a) a

Defined in System.Logger.Internal.Queue

Methods

newQueue :: Natural -> IO (TBMChan a)

closeQueue :: TBMChan a -> IO ()

writeQueue :: TBMChan a -> a -> IO Bool

tryWriteQueue :: TBMChan a -> a -> IO (Maybe Bool)

readQueue :: TBMChan a -> IO (Maybe a)

BoundedCloseableQueue (FairTBMQueue a) a

Defined in System.Logger.Internal.Queue

Methods

newQueue :: Natural -> IO (FairTBMQueue a)

closeQueue :: FairTBMQueue a -> IO ()

writeQueue :: FairTBMQueue a -> a -> IO Bool

tryWriteQueue :: FairTBMQueue a -> a -> IO (Maybe Bool)

readQueue :: FairTBMQueue a -> IO (Maybe a)

data FairTBMQueue α

Instances

BoundedCloseableQueue (FairTBMQueue a) a

Defined in System.Logger.Internal.Queue

Methods

newQueue :: Natural -> IO (FairTBMQueue a)

closeQueue :: FairTBMQueue a -> IO ()

writeQueue :: FairTBMQueue a -> a -> IO Bool

tryWriteQueue :: FairTBMQueue a -> a -> IO (Maybe Bool)

readQueue :: FairTBMQueue a -> IO (Maybe a)

data TBMQueue a

TBMQueue is an abstract type representing a bounded closeable FIFO queue.

Instances

BoundedCloseableQueue (TBMQueue a) a

Defined in System.Logger.Internal.Queue

Methods

newQueue :: Natural -> IO (TBMQueue a)

closeQueue :: TBMQueue a -> IO ()

writeQueue :: TBMQueue a -> a -> IO Bool

tryWriteQueue :: TBMQueue a -> a -> IO (Maybe Bool)

readQueue :: TBMQueue a -> IO (Maybe a)

data TBMChan a

TBMChan is an abstract type representing a bounded closeable FIFO channel.

Instances

BoundedCloseableQueue (TBMChan a) a

Defined in System.Logger.Internal.Queue

Methods

newQueue :: Natural -> IO (TBMChan a)

closeQueue :: TBMChan a -> IO ()

writeQueue :: TBMChan a -> a -> IO Bool

tryWriteQueue :: TBMChan a -> a -> IO (Maybe Bool)

readQueue :: TBMChan a -> IO (Maybe a)