Documentation

(.:) :: (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 :: ProcessId -> (MonitorRef -> Process a) -> Process a #

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