Documentation

type WorkerM = WorkerT Socket IO Source #

startWorkerM :: String -> WorkerM () -> IO () Source #

ping :: (MonadUnliftIO m, Transport tp) => WorkerT tp m Bool Source #

addFunc :: (MonadUnliftIO m, Transport tp) => FuncName -> JobT tp m () -> WorkerT tp m () Source #

broadcast :: (MonadUnliftIO m, Transport tp) => FuncName -> JobT tp m () -> WorkerT tp m () Source #

removeFunc :: (MonadUnliftIO m, Transport tp) => FuncName -> WorkerT tp m () Source #

work :: (MonadUnliftIO m, Transport tp) => Int -> WorkerT tp m () Source #

close :: (MonadUnliftIO m, Transport tp) => WorkerT tp m () Source #