Control.TimeWarp.Rpc.MsgPackRpc

This module contains implementation of MonadRpc for real mode (network, time- and thread-management capabilities provided by OS are used).

Documentation

data MsgPackRpc a

Wrapper over TimedIO, which implements MonadRpc using msgpack-rpc.

Instances

Monad MsgPackRpc

Methods

(>>=) :: MsgPackRpc a -> (a -> MsgPackRpc b) -> MsgPackRpc b

(>>) :: MsgPackRpc a -> MsgPackRpc b -> MsgPackRpc b

return :: a -> MsgPackRpc a

fail :: String -> MsgPackRpc a

Functor MsgPackRpc

Methods

fmap :: (a -> b) -> MsgPackRpc a -> MsgPackRpc b

(<$) :: a -> MsgPackRpc b -> MsgPackRpc a

Applicative MsgPackRpc

Methods

pure :: a -> MsgPackRpc a

(<*>) :: MsgPackRpc (a -> b) -> MsgPackRpc a -> MsgPackRpc b

(*>) :: MsgPackRpc a -> MsgPackRpc b -> MsgPackRpc b

(<*) :: MsgPackRpc a -> MsgPackRpc b -> MsgPackRpc a

MonadThrow MsgPackRpc

Methods

throwM :: Exception e => e -> MsgPackRpc a

MonadIO MsgPackRpc

Methods

liftIO :: IO a -> MsgPackRpc a

MonadCatch MsgPackRpc

Methods

catch :: Exception e => MsgPackRpc a -> (e -> MsgPackRpc a) -> MsgPackRpc a

MonadMask MsgPackRpc

Methods

mask :: ((forall a. MsgPackRpc a -> MsgPackRpc a) -> MsgPackRpc b) -> MsgPackRpc b

uninterruptibleMask :: ((forall a. MsgPackRpc a -> MsgPackRpc a) -> MsgPackRpc b) -> MsgPackRpc b

MonadTimed MsgPackRpc

Methods

virtualTime :: MsgPackRpc Microsecond

wait :: RelativeToNow -> MsgPackRpc ()

fork :: MsgPackRpc () -> MsgPackRpc (ThreadId MsgPackRpc)

myThreadId :: MsgPackRpc (ThreadId MsgPackRpc)

throwTo :: Exception e => ThreadId MsgPackRpc -> e -> MsgPackRpc ()

timeout :: TimeUnit t => t -> MsgPackRpc a -> MsgPackRpc a

MonadRpc MsgPackRpc

Methods

execClient :: MessagePack a => NetworkAddress -> Client a -> MsgPackRpc a

serve :: Port -> [Method MsgPackRpc] -> MsgPackRpc ()

MonadBaseControl IO MsgPackRpc

Associated Types

type StM (MsgPackRpc :: * -> *) a :: *

Methods

liftBaseWith :: (RunInBase MsgPackRpc IO -> IO a) -> MsgPackRpc a

restoreM :: StM MsgPackRpc a -> MsgPackRpc a

MonadBase IO MsgPackRpc

Methods

liftBase :: IO α -> MsgPackRpc α

MethodType MsgPackRpc f => MethodType MsgPackRpc (MsgPackRpc f)

Methods

toBody :: MsgPackRpc f -> [Object] -> MsgPackRpc Object

type ThreadId MsgPackRpc

type ThreadId MsgPackRpc = ThreadId

type StM MsgPackRpc a

type StM MsgPackRpc a = a

runMsgPackRpc :: MsgPackRpc a -> IO a