Control.Concurrent.EQueue.Simple

Simple compatability newtype wrappers to standard queues used in the Haskell wild.

Documentation

data JustOneEventually

A policy for waiting until a single event can be gotten and returning just one. Since these standard queing options are fairly simple the don't allows more detailed policies abiding by EQueue's laws.

Constructors

JustOneEventually

newtype ChanEQueue a

A wrapper for EQueueing events into a Chan.

Constructors

CEQ (Chan a)

Instances

EQueueW ChanEQueue

Defined in Control.Concurrent.EQueue.Simple

Associated Types

type WaitPolicy ChanEQueue :: Type

Methods

waitEQ :: MonadIO m => ChanEQueue a -> WaitPolicy ChanEQueue -> m [a]

EQueue ChanEQueue

Can not unregister events

Defined in Control.Concurrent.EQueue.Simple

Methods

registerSemi :: (MonadIO m, Semigroup b) => ChanEQueue a -> (b -> a) -> m (b -> IO (), IO ())

registerQueued :: MonadIO m => ChanEQueue a -> m (a -> IO (), IO ())

type WaitPolicy ChanEQueue

Defined in Control.Concurrent.EQueue.Simple

type WaitPolicy ChanEQueue = JustOneEventually

newtype TChanEQueue a

A wrapper for EQueueing events into a TChan.

Constructors

TCEQ (TChan a)

Instances

EQueueW TChanEQueue

Defined in Control.Concurrent.EQueue.Simple

Associated Types

type WaitPolicy TChanEQueue :: Type

Methods

waitEQ :: MonadIO m => TChanEQueue a -> WaitPolicy TChanEQueue -> m [a]

EQueue TChanEQueue

Can not unregister events

Defined in Control.Concurrent.EQueue.Simple

Methods

registerSemi :: (MonadIO m, Semigroup b) => TChanEQueue a -> (b -> a) -> m (b -> IO (), IO ())

registerQueued :: MonadIO m => TChanEQueue a -> m (a -> IO (), IO ())

type WaitPolicy TChanEQueue

Defined in Control.Concurrent.EQueue.Simple

type WaitPolicy TChanEQueue = JustOneEventually

newtype TQueueEQueue a

A wrapper for EQueueing events into a TQueue.

Constructors

TQEQ (TQueue a)

Instances

EQueueW TQueueEQueue

Defined in Control.Concurrent.EQueue.Simple

Associated Types

type WaitPolicy TQueueEQueue :: Type

Methods

waitEQ :: MonadIO m => TQueueEQueue a -> WaitPolicy TQueueEQueue -> m [a]

EQueue TQueueEQueue

Can not unregister events

Defined in Control.Concurrent.EQueue.Simple

Methods

registerSemi :: (MonadIO m, Semigroup b) => TQueueEQueue a -> (b -> a) -> m (b -> IO (), IO ())

registerQueued :: MonadIO m => TQueueEQueue a -> m (a -> IO (), IO ())

type WaitPolicy TQueueEQueue

Defined in Control.Concurrent.EQueue.Simple

type WaitPolicy TQueueEQueue = JustOneEventually

newtype IOEQueue a

A wrapper for EQueueing events that we have an IO action to submit.

Constructors

IOEQ (a -> IO ())

Instances

EQueue IOEQueue

Defined in Control.Concurrent.EQueue.Simple

Methods

registerSemi :: (MonadIO m, Semigroup b) => IOEQueue a -> (b -> a) -> m (b -> IO (), IO ())

registerQueued :: MonadIO m => IOEQueue a -> m (a -> IO (), IO ())