Control.Eff.Concurrent.GenServer

Type safe server API processes

Documentation

data family Api (genServerModule :: Type) (replyType :: Synchronicity)

This data family defines an API implemented by a server. The first parameter is the API index and the second parameter (the * -> *)

Instances

Show (Observation o) => Show (Api (CallbackObserver o) r)

Methods

showsPrec :: Int -> Api (CallbackObserver o) r -> ShowS

show :: Api (CallbackObserver o) r -> String

showList :: [Api (CallbackObserver o) r] -> ShowS

data Api (CallbackObserver o)

data Api (CallbackObserver o) where

• CbObserved :: Api (CallbackObserver o) Asynchronous

data Synchronicity

Constructors

Synchronous Type

Asynchronous

data ApiHandler p r e

Constructors

ApiHandler ((Typeable p, Typeable (Api p Asynchronous), HasCallStack) => Api p Asynchronous -> Eff r e) (forall x. (Typeable p, Typeable (Api p (Synchronous x)), Typeable x, HasCallStack) => Api p (Synchronous x) -> (x -> Eff r Bool) -> Eff r e) ((Typeable p, HasCallStack) => String -> Eff r ())

newtype Server genServerModule

Constructors

Server

Fields

• _fromServer :: ProcessId

Instances

Eq (Server genServerModule)

Methods

(==) :: Server genServerModule -> Server genServerModule -> Bool

(/=) :: Server genServerModule -> Server genServerModule -> Bool

Ord (Server genServerModule)

Methods

compare :: Server genServerModule -> Server genServerModule -> Ordering

(<) :: Server genServerModule -> Server genServerModule -> Bool

(<=) :: Server genServerModule -> Server genServerModule -> Bool

(>) :: Server genServerModule -> Server genServerModule -> Bool

(>=) :: Server genServerModule -> Server genServerModule -> Bool

max :: Server genServerModule -> Server genServerModule -> Server genServerModule

min :: Server genServerModule -> Server genServerModule -> Server genServerModule

Read (Server genServerModule)

Methods

readsPrec :: Int -> ReadS (Server genServerModule)

readList :: ReadS [Server genServerModule]

readPrec :: ReadPrec (Server genServerModule)

readListPrec :: ReadPrec [Server genServerModule]

Typeable * genServerModule => Show (Server genServerModule)

Methods

showsPrec :: Int -> Server genServerModule -> ShowS

show :: Server genServerModule -> String

showList :: [Server genServerModule] -> ShowS

fromServer :: forall genServerModule genServerModule. Iso (Server genServerModule) (Server genServerModule) ProcessId ProcessId

proxyAsServer :: proxy genServerModule -> ProcessId -> Server genServerModule

asServer :: forall genServerModule. ProcessId -> Server genServerModule

cast :: forall r o. (HasCallStack, Member MessagePassing r, Typeable o, Typeable (Api o Asynchronous)) => Server o -> Api o Asynchronous -> Eff r Bool

cast_ :: forall r o. (HasCallStack, Member MessagePassing r, Typeable o, Typeable (Api o Asynchronous)) => Server o -> Api o Asynchronous -> Eff r ()

call :: forall result genServerModule r. (Member MessagePassing r, Member Process r, Typeable genServerModule, Typeable (Api genServerModule (Synchronous result)), Typeable result, HasCallStack) => Server genServerModule -> Api genServerModule (Synchronous result) -> Eff r (Message result)

serve :: forall r p e. (Typeable p, Member MessagePassing r, Member Process r, HasCallStack) => ApiHandler p r e -> Eff r (Message e)

serve_ :: forall r p. (Typeable p, Member MessagePassing r, Member Process r, HasCallStack) => ApiHandler p r () -> Eff r ()

unhandledCallError :: (Show (Api p (Synchronous x)), Typeable p, Typeable (Api p (Synchronous x)), Typeable x, HasCallStack, Member Process r) => Api p (Synchronous x) -> (x -> Eff r Bool) -> Eff r e

unhandledCastError :: (Show (Api p Asynchronous), Typeable p, Typeable (Api p Asynchronous), HasCallStack, Member Process r) => Api p Asynchronous -> Eff r e