| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Control.Distributed.Process.Lifted
- (.:) :: (c -> d) -> (a -> b -> c) -> a -> b -> d
- spawnLocal :: MonadProcessBase m => m () -> m ProcessId
- getSelfPid :: MonadProcess m => m ProcessId
- expect :: MonadProcess m => forall a. Serializable a => m a
- expectTimeout :: MonadProcess m => forall a. Serializable a => Int -> m (Maybe a)
- register :: MonadProcess m => String -> ProcessId -> m ()
- whereis :: MonadProcess m => String -> m (Maybe ProcessId)
- catchesExit :: forall m a. MonadProcessBase m => m a -> [ProcessId -> Message -> m (Maybe a)] -> m a
- delegate :: MonadProcess m => ProcessId -> (Message -> Bool) -> m ()
- forward :: MonadProcess m => Message -> ProcessId -> m ()
- getLocalNodeStats :: MonadProcess m => m NodeStats
- getNodeStats :: MonadProcess m => NodeId -> m (Either DiedReason NodeStats)
- getProcessInfo :: MonadProcess m => ProcessId -> m (Maybe ProcessInfo)
- getSelfNode :: MonadProcess m => m NodeId
- kill :: MonadProcess m => ProcessId -> String -> m ()
- link :: MonadProcess m => ProcessId -> m ()
- linkNode :: MonadProcess m => NodeId -> m ()
- linkPort :: MonadProcess m => SendPort a -> m ()
- monitor :: MonadProcess m => ProcessId -> m MonitorRef
- monitorNode :: MonadProcess m => NodeId -> m MonitorRef
- receiveTimeout :: MonadProcess m => Int -> [Match b] -> m (Maybe b)
- receiveWait :: MonadProcess m => [Match b] -> m b
- reconnect :: MonadProcess m => ProcessId -> m ()
- reconnectPort :: MonadProcess m => SendPort a -> m ()
- registerRemoteAsync :: MonadProcess m => NodeId -> String -> ProcessId -> m ()
- relay :: MonadProcess m => ProcessId -> m ()
- reregister :: MonadProcess m => String -> ProcessId -> m ()
- reregisterRemoteAsync :: MonadProcess m => NodeId -> String -> ProcessId -> m ()
- say :: MonadProcess m => String -> m ()
- spawn :: MonadProcess m => NodeId -> Closure (Process ()) -> m ProcessId
- spawnAsync :: MonadProcess m => NodeId -> Closure (Process ()) -> m SpawnRef
- spawnLink :: MonadProcess m => NodeId -> Closure (Process ()) -> m ProcessId
- spawnMonitor :: MonadProcess m => NodeId -> Closure (Process ()) -> m (ProcessId, MonitorRef)
- spawnSupervised :: MonadProcess m => NodeId -> Closure (Process ()) -> m (ProcessId, MonitorRef)
- terminate :: MonadProcess m => m a
- unlink :: MonadProcess m => ProcessId -> m ()
- unlinkNode :: MonadProcess m => NodeId -> m ()
- unlinkPort :: MonadProcess m => SendPort a -> m ()
- unmonitor :: MonadProcess m => MonitorRef -> m ()
- unregister :: MonadProcess m => String -> m ()
- unregisterRemoteAsync :: MonadProcess m => NodeId -> String -> m ()
- whereisRemoteAsync :: MonadProcess m => NodeId -> String -> m ()
- withMonitor :: MonadProcessBase m => ProcessId -> m a -> m a
- call :: (MonadProcess m, Serializable a) => Static (SerializableDict a) -> NodeId -> Closure (Process a) -> m a
- catchExit :: (MonadProcessBase m, Show a, Serializable a) => m b -> (ProcessId -> a -> m b) -> m b
- die :: (MonadProcess m, Serializable a) => a -> m b
- exit :: (MonadProcess m, Serializable a) => ProcessId -> a -> m ()
- handleMessage :: (MonadProcess m, Serializable a) => Message -> (a -> Process b) -> m (Maybe b)
- handleMessageIf :: (MonadProcess m, Serializable a) => Message -> (a -> Bool) -> (a -> Process b) -> m (Maybe b)
- handleMessageIf_ :: (MonadProcess m, Serializable a) => Message -> (a -> Bool) -> (a -> Process ()) -> m ()
- handleMessage_ :: (MonadProcess m, Serializable a) => Message -> (a -> Process ()) -> m ()
- mergePortsBiased :: (MonadProcess m, Serializable a) => [ReceivePort a] -> m (ReceivePort a)
- mergePortsRR :: (MonadProcess m, Serializable a) => [ReceivePort a] -> m (ReceivePort a)
- monitorPort :: (MonadProcess m, Serializable a) => SendPort a -> m MonitorRef
- newChan :: (MonadProcess m, Serializable a) => m (SendPort a, ReceivePort a)
- nsend :: (MonadProcess m, Serializable a) => String -> a -> m ()
- nsendRemote :: (MonadProcess m, Serializable a) => NodeId -> String -> a -> m ()
- proxy :: (MonadProcess m, Serializable a) => ProcessId -> (a -> Process Bool) -> m ()
- receiveChan :: (MonadProcess m, Serializable a) => ReceivePort a -> m a
- receiveChanTimeout :: (MonadProcess m, Serializable a) => Int -> ReceivePort a -> m (Maybe a)
- send :: (MonadProcess m, Serializable a) => ProcessId -> a -> m ()
- sendChan :: (MonadProcess m, Serializable a) => SendPort a -> a -> m ()
- spawnChannel :: (MonadProcess m, Serializable a) => Static (SerializableDict a) -> NodeId -> Closure (ReceivePort a -> Process ()) -> m (SendPort a)
- spawnChannelLocal :: (MonadProcess m, Serializable a) => (ReceivePort a -> Process ()) -> m (SendPort a)
- unClosure :: (MonadProcess m, Typeable a) => Closure a -> m a
- unStatic :: (MonadProcess m, Typeable a) => Static a -> m a
- unsafeNSend :: (MonadProcess m, Serializable a) => String -> a -> m ()
- unsafeSend :: (MonadProcess m, Serializable a) => ProcessId -> a -> m ()
- unsafeSendChan :: (MonadProcess m, Serializable a) => SendPort a -> a -> m ()
- unwrapMessage :: (MonadProcess m, Serializable a) => Message -> m (Maybe a)
- module Control.Distributed.Process
- module Control.Exception.Lifted
Documentation
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
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
getLocalNodeStats :: MonadProcess m => m NodeStats Source
Generalized version of getLocalNodeStats
getNodeStats :: MonadProcess m => NodeId -> m (Either DiedReason NodeStats) Source
Generalized version of getNodeStats
getProcessInfo :: MonadProcess m => ProcessId -> m (Maybe ProcessInfo) Source
Generalized version of getProcessInfo
getSelfNode :: MonadProcess m => m NodeId Source
Generalized version of getSelfNode
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
registerRemoteAsync :: MonadProcess m => NodeId -> String -> ProcessId -> m () Source
Generalized version of registerRemoteAsync
relay :: MonadProcess m => ProcessId -> m () Source
Generalized version of relay
reregister :: MonadProcess m => String -> ProcessId -> m () Source
Generalized version of reregister
reregisterRemoteAsync :: MonadProcess m => NodeId -> String -> ProcessId -> m () Source
Generalized version of reregisterRemoteAsync
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
spawnSupervised :: MonadProcess m => NodeId -> Closure (Process ()) -> m (ProcessId, MonitorRef) Source
Generalized version of spawnSupervised
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
unregisterRemoteAsync :: MonadProcess m => NodeId -> String -> m () Source
Generalized version of unregisterRemoteAsync
whereisRemoteAsync :: MonadProcess m => NodeId -> String -> m () Source
Generalized version of whereisRemoteAsync
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_
mergePortsBiased :: (MonadProcess m, Serializable a) => [ReceivePort a] -> m (ReceivePort a) Source
Generalized version of mergePortsBiased
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
receiveChanTimeout :: (MonadProcess m, Serializable a) => Int -> ReceivePort a -> m (Maybe a) Source
Generalized version of receiveChanTimeout
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
spawnChannel :: (MonadProcess m, Serializable a) => Static (SerializableDict a) -> NodeId -> Closure (ReceivePort a -> Process ()) -> m (SendPort a) Source
Generalized version of spawnChannel
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
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
module Control.Distributed.Process
module Control.Exception.Lifted