Transient.Mailboxes

Documentation

mailboxes :: IORef (Map MailboxId (EVar SData))

data MailboxId

Constructors

(Typeable a, Ord a) => MailboxId a TypeRep

Instances

Eq MailboxId

Defined in Transient.Mailboxes

Methods

(==) :: MailboxId -> MailboxId -> Bool

(/=) :: MailboxId -> MailboxId -> Bool

Ord MailboxId

Defined in Transient.Mailboxes

Methods

compare :: MailboxId -> MailboxId -> Ordering

(<) :: MailboxId -> MailboxId -> Bool

(<=) :: MailboxId -> MailboxId -> Bool

(>) :: MailboxId -> MailboxId -> Bool

(>=) :: MailboxId -> MailboxId -> Bool

max :: MailboxId -> MailboxId -> MailboxId

min :: MailboxId -> MailboxId -> MailboxId

Show MailboxId

Defined in Transient.Mailboxes

Methods

showsPrec :: Int -> MailboxId -> ShowS

show :: MailboxId -> String

showList :: [MailboxId] -> ShowS

putMailbox :: Typeable val => val -> TransIO ()

write to the mailbox Mailboxes are node-wide, for all processes that share the same connection data, that is, are under the same listen or connect while EVars are only visible by the process that initialized it and his children. Internally, the mailbox is in a well known EVar stored by listen in the Connection state.

putMailbox' :: (Typeable key, Ord key, Typeable val) => key -> val -> TransIO ()

write to a mailbox identified by an identifier besides the type

newMailbox :: MailboxId -> TransIO ()

getMailbox :: Typeable val => TransIO val

get messages from the mailbox that matches with the type expected. The order of reading is defined by readTChan This is reactive. it means that each new message trigger the execution of the continuation each message wake up all the getMailbox computations waiting for it.

getMailbox' :: (Typeable key, Ord key, Typeable val) => key -> TransIO val

read from a mailbox identified by an identifier besides the type

deleteMailbox :: Typeable a => a -> TransIO ()

delete all subscriptions for that mailbox expecting this kind of data

deleteMailbox' :: (Typeable key, Ord key, Typeable a) => key -> a -> TransIO ()

clean a mailbox identified by an Int and the type