Control.Eff.Concurrent.Api

This module contains a mechanism to specify what kind of messages (aka requests) a Server (Process) can handle, and if the caller blocks and waits for an answer, which the server process provides.

The type magic in the Api type familiy allows to define a related set of requests along with the corresponding responses.

Request handling can be either blocking, if a response is requred, or non-blocking.

A process can serve a specific Api instance by using the functions provided by the Control.Eff.Concurrent.Api.Server module.

To enable a process to use such a service, the functions provided by the Control.Eff.Concurrent.Api.Client should be used.

Documentation

data family Api (api :: Type) (reply :: Synchronicity)

This data family defines an API, a communication interface description between at least two processes. The processes act as servers or client(s) regarding a specific instance of this type.

The first parameter is usually a user defined phantom type that identifies the Api instance.

The second parameter specifies if a specific constructor of an (GADT-like) Api instance is Synchronous, i.e. returns a result and blocks the caller or if it is Asynchronous

Example:

data BookShop deriving Typeable

data instance Api BookShop r where
  RentBook  :: BookId   -> Api BookShop ('Synchronous (Either RentalError RentalId))
  BringBack :: RentalId -> Api BookShop 'Asynchronous

type BookId = Int
type RentalId = Int
type RentalError = String

Instances

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

Defined in Control.Eff.Concurrent.Api.Observer

Methods

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

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

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

data Api (CallbackObserver o) r

Defined in Control.Eff.Concurrent.Api.Observer

data Api (CallbackObserver o) r where

• CbObserved :: Api (CallbackObserver o) Asynchronous

data Synchronicity

The (promoted) constructors of this type specify (at the type level) the reply behavior of a specific constructor of an Api instance.

Constructors

Synchronous Type

Specify that handling a request is a blocking operation with a specific return type, e.g. ('Synchronous (Either RentalError RentalId))

Asynchronous

Non-blocking, asynchronous, request handling

newtype Server api

This is a tag-type that wraps around a ProcessId and holds an Api index type.

Constructors

Server

Fields

• _fromServer :: ProcessId

Instances

Eq (Server api)

Defined in Control.Eff.Concurrent.Api

Methods

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

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

Ord (Server api)

Defined in Control.Eff.Concurrent.Api

Methods

compare :: Server api -> Server api -> Ordering

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

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

(>) :: Server api -> Server api -> Bool

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

max :: Server api -> Server api -> Server api

min :: Server api -> Server api -> Server api

Read (Server api)

Defined in Control.Eff.Concurrent.Api

Methods

readsPrec :: Int -> ReadS (Server api)

readList :: ReadS [Server api]

readPrec :: ReadPrec (Server api)

readListPrec :: ReadPrec [Server api]

Typeable api => Show (Server api)

Defined in Control.Eff.Concurrent.Api

Methods

showsPrec :: Int -> Server api -> ShowS

show :: Server api -> String

showList :: [Server api] -> ShowS

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

proxyAsServer :: proxy api -> ProcessId -> Server api

Tag a ProcessId with an Api type index to mark it a Server process handling that API

asServer :: forall api. ProcessId -> Server api

Tag a ProcessId with an Api type index to mark it a Server process handling that API