distributed-process-lifted-0.3.0.1: monad-control style typeclass and transformer instances for Process monad.

Safe HaskellNone
LanguageHaskell2010

Control.Distributed.Process.Lifted

Synopsis

Documentation

(.:) :: (c -> d) -> (a -> b -> c) -> a -> b -> d Source #

spawnLocal :: MonadProcessBase m => m () -> m ProcessId Source #

Generalized version of spawnLocal

getSelfPid :: MonadProcess m => m ProcessId Source #

Generalized version of getSelfPid

expect :: MonadProcess m => forall a. Serializable a => m a Source #

Generalized version of expect

expectTimeout :: MonadProcess m => forall a. Serializable a => Int -> m (Maybe a) Source #

Generalized version of expectTimeout

register :: MonadProcess m => String -> ProcessId -> m () Source #

Generalized version of register

whereis :: MonadProcess m => String -> m (Maybe ProcessId) Source #

Generalized version of whereis

catchesExit :: forall m a. MonadProcessBase m => m a -> [ProcessId -> Message -> m (Maybe a)] -> m a Source #

Generalized version of catchesExit

delegate :: MonadProcess m => ProcessId -> (Message -> Bool) -> m () Source #

Generalized version of delegate

forward :: MonadProcess m => Message -> ProcessId -> m () Source #

Generalized version of forward

getSelfNode :: MonadProcess m => m NodeId Source #

Generalized version of getSelfNode

kill :: MonadProcess m => ProcessId -> String -> m () Source #

Generalized version of kill

link :: MonadProcess m => ProcessId -> m () Source #

Generalized version of link

linkNode :: MonadProcess m => NodeId -> m () Source #

Generalized version of linkNode

linkPort :: MonadProcess m => SendPort a -> m () Source #

Generalized version of linkPort

monitor :: MonadProcess m => ProcessId -> m MonitorRef Source #

Generalized version of monitor

monitorNode :: MonadProcess m => NodeId -> m MonitorRef Source #

Generalized version of monitorNode

receiveTimeout :: MonadProcess m => Int -> [Match b] -> m (Maybe b) Source #

Generalized version of receiveTimeout

receiveWait :: MonadProcess m => [Match b] -> m b Source #

Generalized version of receiveWait

reconnect :: MonadProcess m => ProcessId -> m () Source #

Generalized version of reconnect

reconnectPort :: MonadProcess m => SendPort a -> m () Source #

Generalized version of reconnectPort

relay :: MonadProcess m => ProcessId -> m () Source #

Generalized version of relay

reregister :: MonadProcess m => String -> ProcessId -> m () Source #

Generalized version of reregister

say :: MonadProcess m => String -> m () Source #

Generalized version of say

spawn :: MonadProcess m => NodeId -> Closure (Process ()) -> m ProcessId Source #

Generalized version of spawn

spawnAsync :: MonadProcess m => NodeId -> Closure (Process ()) -> m SpawnRef Source #

Generalized version of spawnAsync

spawnLink :: MonadProcess m => NodeId -> Closure (Process ()) -> m ProcessId Source #

Generalized version of spawnLink

spawnMonitor :: MonadProcess m => NodeId -> Closure (Process ()) -> m (ProcessId, MonitorRef) Source #

Generalized version of spawnMonitor

terminate :: MonadProcess m => m a Source #

Generalized version of terminate

unlink :: MonadProcess m => ProcessId -> m () Source #

Generalized version of unlink

unlinkNode :: MonadProcess m => NodeId -> m () Source #

Generalized version of unlinkNode

unlinkPort :: MonadProcess m => SendPort a -> m () Source #

Generalized version of unlinkPort

unmonitor :: MonadProcess m => MonitorRef -> m () Source #

Generalized version of unmonitor

unregister :: MonadProcess m => String -> m () Source #

Generalized version of unregister

whereisRemoteAsync :: MonadProcess m => NodeId -> String -> m () Source #

Generalized version of whereisRemoteAsync

withMonitor :: ProcessId -> (MonitorRef -> Process a) -> Process a Source #

Generalized version of withMonitor

withMonitor_ :: MonadProcessBase m => ProcessId -> m a -> m a Source #

Generalized version of withMonitor_

call :: (MonadProcess m, Serializable a) => Static (SerializableDict a) -> NodeId -> Closure (Process a) -> m a Source #

Generalized version of call

catchExit :: (MonadProcessBase m, Show a, Serializable a) => m b -> (ProcessId -> a -> m b) -> m b Source #

Generalized version of catchExit

die :: (MonadProcess m, Serializable a) => a -> m b Source #

Generalized version of die

exit :: (MonadProcess m, Serializable a) => ProcessId -> a -> m () Source #

Generalized version of exit

handleMessage :: (MonadProcess m, Serializable a) => Message -> (a -> Process b) -> m (Maybe b) Source #

Generalized version of handleMessage

handleMessageIf :: (MonadProcess m, Serializable a) => Message -> (a -> Bool) -> (a -> Process b) -> m (Maybe b) Source #

Generalized version of handleMessageIf

handleMessageIf_ :: (MonadProcess m, Serializable a) => Message -> (a -> Bool) -> (a -> Process ()) -> m () Source #

Generalized version of handleMessageIf_

handleMessage_ :: (MonadProcess m, Serializable a) => Message -> (a -> Process ()) -> m () Source #

Generalized version of handleMessage_

mergePortsRR :: (MonadProcess m, Serializable a) => [ReceivePort a] -> m (ReceivePort a) Source #

Generalized version of mergePortsRR

monitorPort :: (MonadProcess m, Serializable a) => SendPort a -> m MonitorRef Source #

Generalized version of monitorPort

newChan :: (MonadProcess m, Serializable a) => m (SendPort a, ReceivePort a) Source #

Generalized version of newChan

nsend :: (MonadProcess m, Serializable a) => String -> a -> m () Source #

Generalized version of nsend

nsendRemote :: (MonadProcess m, Serializable a) => NodeId -> String -> a -> m () Source #

Generalized version of nsendRemote

proxy :: (MonadProcess m, Serializable a) => ProcessId -> (a -> Process Bool) -> m () Source #

Generalized version of proxy

receiveChan :: (MonadProcess m, Serializable a) => ReceivePort a -> m a Source #

Generalized version of receiveChan

send :: (MonadProcess m, Serializable a) => ProcessId -> a -> m () Source #

Generalized version of send

sendChan :: (MonadProcess m, Serializable a) => SendPort a -> a -> m () Source #

Generalized version of sendChan

spawnChannelLocal :: (MonadProcess m, Serializable a) => (ReceivePort a -> Process ()) -> m (SendPort a) Source #

Generalized version of spawnChannelLocal

unClosure :: (MonadProcess m, Typeable a) => Closure a -> m a Source #

Generalized version of unClosure

unStatic :: (MonadProcess m, Typeable a) => Static a -> m a Source #

Generalized version of unStatic

unsafeNSend :: (MonadProcess m, Serializable a) => String -> a -> m () Source #

Generalized version of unsafeNSend

unsafeSend :: (MonadProcess m, Serializable a) => ProcessId -> a -> m () Source #

Generalized version of unsafeSend

unsafeSendChan :: (MonadProcess m, Serializable a) => SendPort a -> a -> m () Source #

Generalized version of unsafeSendChan

unwrapMessage :: (MonadProcess m, Serializable a) => Message -> m (Maybe a) Source #

Generalized version of unwrapMessage