Control.Distributed.Process.Internal.MessageT

Add message sending capability to a monad

NOTE: Not thread-safe (you should not do concurrent sends within the same monad).

Documentation

data MessageT m a

Instances

Monad m => MonadState MessageState (MessageT m)

Monad m => Monad (MessageT m)

Functor m => Functor (MessageT m)

(Monad m, Functor m) => Applicative (MessageT m)

MonadIO m => MonadIO (MessageT m)

runMessageT :: Monad m => LocalNode -> MessageT m a -> m a

getLocalNode :: Monad m => MessageT m LocalNode

sendPayload :: MonadIO m => Identifier -> [ByteString] -> MessageT m ()

sendBinary :: (MonadIO m, Binary a) => Identifier -> a -> MessageT m ()

sendMessage :: (MonadIO m, Serializable a) => Identifier -> a -> MessageT m ()

payloadToMessage :: [ByteString] -> Message

Deserialize a message

createMessage :: Serializable a => a -> Message

Turn any serialiable term into a message