Control.Concurrent.NQE

Documentation

type Reply a = a -> STM ()

type Listen a = a -> STM ()

class Mailbox mbox where

Minimal complete definition

mailboxEmptySTM, sendSTM, receiveSTM, requeueMsg

Methods

mailboxEmptySTM :: mbox msg -> STM Bool

sendSTM :: msg -> mbox msg -> STM ()

receiveSTM :: mbox msg -> STM msg

requeueMsg :: msg -> mbox msg -> STM ()

Instances

Mailbox TQueue

Defined in Control.Concurrent.NQE.Process

Methods

mailboxEmptySTM :: TQueue msg -> STM Bool

sendSTM :: msg -> TQueue msg -> STM ()

receiveSTM :: TQueue msg -> STM msg

requeueMsg :: msg -> TQueue msg -> STM ()

Mailbox TBQueue

Defined in Control.Concurrent.NQE.Process

Methods

mailboxEmptySTM :: TBQueue msg -> STM Bool

sendSTM :: msg -> TBQueue msg -> STM ()

receiveSTM :: TBQueue msg -> STM msg

requeueMsg :: msg -> TBQueue msg -> STM ()

Mailbox Inbox

Defined in Control.Concurrent.NQE.Process

Methods

mailboxEmptySTM :: Inbox msg -> STM Bool

sendSTM :: msg -> Inbox msg -> STM ()

receiveSTM :: Inbox msg -> STM msg

requeueMsg :: msg -> Inbox msg -> STM ()

data Inbox msg

Constructors

Mailbox mbox => Inbox (mbox msg)

Instances

Mailbox Inbox

Defined in Control.Concurrent.NQE.Process

Methods

mailboxEmptySTM :: Inbox msg -> STM Bool

sendSTM :: msg -> Inbox msg -> STM ()

receiveSTM :: Inbox msg -> STM msg

requeueMsg :: msg -> Inbox msg -> STM ()

mailboxEmpty :: (MonadIO m, Mailbox mbox) => mbox msg -> m Bool

send :: (MonadIO m, Mailbox mbox) => msg -> mbox msg -> m ()

requeue :: Mailbox mbox => [msg] -> mbox msg -> STM ()

extractMsg :: Mailbox mbox => [(msg -> Maybe a, a -> b)] -> mbox msg -> STM b

query :: (MonadIO m, Mailbox mbox) => (Reply b -> msg) -> mbox msg -> m b

dispatch

Arguments

:: (MonadIO m, Mailbox mbox)

=> [(msg -> Maybe a, a -> m b)]

action to dispatch

-> mbox msg

mailbox to read from

-> m b

dispatchSTM :: Mailbox mbox => [msg -> Maybe a] -> mbox msg -> STM a

receive :: (MonadIO m, Mailbox mbox) => mbox msg -> m msg

receiveMatch :: (MonadIO m, Mailbox mbox) => mbox msg -> (msg -> Maybe a) -> m a

receiveMatchSTM :: Mailbox mbox => mbox msg -> (msg -> Maybe a) -> STM a

fromSource

Arguments

:: (MonadIO m, Mailbox mbox)

=> ConduitT () msg m ()

-> mbox msg

will receive all messages

-> m ()

withSource :: (MonadUnliftIO m, Mailbox mbox) => ConduitT () msg m () -> mbox msg -> (Async () -> m a) -> m a

data SupervisorMessage n

Constructors

MonadUnliftIO n => AddChild (n ()) (Reply (Async ()))

RemoveChild (Async ())

StopSupervisor

data Strategy

Constructors

Notify ((Async (), Either SomeException ()) -> STM ())

KillAll

IgnoreGraceful

IgnoreAll

supervisor :: (MonadUnliftIO m, Mailbox mbox) => Strategy -> mbox (SupervisorMessage m) -> [m ()] -> m ()

addChild :: (MonadUnliftIO n, MonadIO m, Mailbox mbox) => mbox (SupervisorMessage n) -> n () -> m (Async ())

removeChild :: (MonadUnliftIO n, MonadIO m, Mailbox mbox) => mbox (SupervisorMessage n) -> Async () -> m ()

stopSupervisor :: (MonadUnliftIO n, MonadIO m, Mailbox mbox) => mbox (SupervisorMessage n) -> m ()

type Publisher mbox ch msg = mbox (ControlMsg ch msg)

publisher :: (MonadIO m, Mailbox mbox, Mailbox events, Mailbox ch, Eq (ch msg)) => Publisher mbox ch msg -> events msg -> m ()

boundedPublisher :: (MonadIO m, Mailbox mbox, Mailbox events) => Publisher mbox TBQueue msg -> events msg -> m ()

withPubSub :: (MonadUnliftIO m, Mailbox mbox) => Publisher mbox TQueue msg -> (TQueue msg -> m a) -> m a

withBoundedPubSub :: (MonadUnliftIO m, Mailbox mbox) => Int -> Publisher mbox TBQueue msg -> (TBQueue msg -> m a) -> m a