Control.Distributed.Process.Lifted

Documentation

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

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

Generalized version of spawnLocal

getSelfPid :: MonadProcess m => m ProcessId

Generalized version of getSelfPid

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

Generalized version of expect

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

Generalized version of expectTimeout

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

Generalized version of register

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

Generalized version of whereis

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

Generalized version of catchesExit

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

Generalized version of delegate

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

Generalized version of forward

getLocalNodeStats :: MonadProcess m => m NodeStats

Generalized version of getLocalNodeStats

getNodeStats :: MonadProcess m => NodeId -> m (Either DiedReason NodeStats)

Generalized version of getNodeStats

getProcessInfo :: MonadProcess m => ProcessId -> m (Maybe ProcessInfo)

Generalized version of getProcessInfo

getSelfNode :: MonadProcess m => m NodeId

Generalized version of getSelfNode

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

Generalized version of kill

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

Generalized version of link

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

Generalized version of linkNode

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

Generalized version of linkPort

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

Generalized version of monitor

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

Generalized version of monitorNode

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

Generalized version of receiveTimeout

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

Generalized version of receiveWait

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

Generalized version of reconnect

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

Generalized version of reconnectPort

registerRemoteAsync :: MonadProcess m => NodeId -> String -> ProcessId -> m ()

Generalized version of registerRemoteAsync

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

Generalized version of relay

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

Generalized version of reregister

reregisterRemoteAsync :: MonadProcess m => NodeId -> String -> ProcessId -> m ()

Generalized version of reregisterRemoteAsync

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

Generalized version of say

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

Generalized version of spawn

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

Generalized version of spawnAsync

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

Generalized version of spawnLink

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

Generalized version of spawnMonitor

spawnSupervised :: MonadProcess m => NodeId -> Closure (Process ()) -> m (ProcessId, MonitorRef)

Generalized version of spawnSupervised

terminate :: MonadProcess m => m a

Generalized version of terminate

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

Generalized version of unlink

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

Generalized version of unlinkNode

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

Generalized version of unlinkPort

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

Generalized version of unmonitor

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

Generalized version of unregister

unregisterRemoteAsync :: MonadProcess m => NodeId -> String -> m ()

Generalized version of unregisterRemoteAsync

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

Generalized version of whereisRemoteAsync

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

Generalized version of withMonitor

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

Generalized version of withMonitor_

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

Generalized version of call

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

Generalized version of catchExit

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

Generalized version of die

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

Generalized version of exit

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

Generalized version of handleMessage

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

Generalized version of handleMessageIf

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

Generalized version of handleMessageIf_

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

Generalized version of handleMessage_

mergePortsBiased :: (MonadProcess m, Serializable a) => [ReceivePort a] -> m (ReceivePort a)

Generalized version of mergePortsBiased

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

Generalized version of mergePortsRR

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

Generalized version of monitorPort

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

Generalized version of newChan

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

Generalized version of nsend

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

Generalized version of nsendRemote

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

Generalized version of proxy

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

Generalized version of receiveChan

receiveChanTimeout :: (MonadProcess m, Serializable a) => Int -> ReceivePort a -> m (Maybe a)

Generalized version of receiveChanTimeout

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

Generalized version of send

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

Generalized version of sendChan

spawnChannel :: (MonadProcess m, Serializable a) => Static (SerializableDict a) -> NodeId -> Closure (ReceivePort a -> Process ()) -> m (SendPort a)

Generalized version of spawnChannel

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

Generalized version of spawnChannelLocal

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

Generalized version of unClosure

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

Generalized version of unStatic

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

Generalized version of unsafeNSend

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

Generalized version of unsafeSend

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

Generalized version of unsafeSendChan

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

Generalized version of unwrapMessage

module Control.Distributed.Process

module Control.Exception.Lifted