Choreography.Network.Local

This module defines the multi-thread backend for the Network monad.

Documentation

type MsgBuf = HashMap LocTm (Chan String)

Each location is associated with a message buffer which stores messages sent from other locations.

newtype LocalConfig

A backend for running choreographies using Haskell threads as the locations and buffered Chan channels for communication.

Constructors

LocalConfig

Fields

• locToBuf :: HashMap LocTm MsgBuf

Instances

Backend LocalConfig

Defined in Choreography.Network.Local

Methods

runNetwork :: MonadIO m => LocalConfig -> LocTm -> Network m a -> m a

newEmptyMsgBuf :: [LocTm] -> IO MsgBuf

Make a channel for each of the listed locations, on which messages from that location can be recieved.

mkLocalConfig :: [LocTm] -> IO LocalConfig

Make a local backend for the listed parties. Make just the one backend and then have all your threads use the same one.

locs :: LocalConfig -> [LocTm]

List the parties known to the backend.

runNetworkLocal :: MonadIO m => LocalConfig -> LocTm -> Network m a -> m a

Run a Network behavior using the channels in a LocalConfig for communication. Call this inside a concurrent thread.