Control.Concurrent.CHP.Connect

A module of operators for connecting processes together.

Documentation

class Connectable l r where

Indicates that its two parameters can be joined together automatically.

Rather than use connect directly, you will want to use the operators such as '(=)'. There are different forms of this operator for in the middle of a pipeline (where you still need further parameters to each process), and at the ends. See also pipelineConnect and pipelineConnectComplete.

Methods

connect :: ((l, r) -> CHP a) -> CHP a

Runs the given code with the two items connected.

Instances

Connectable (Chanin a) (Chanout a)

Connectable (Chanout a) (Chanin a)

Connectable (Chanin a) (Shared Chanout a)

Connectable (Chanout a) (Shared Chanin a)

Connectable (Shared Chanin a) (Chanout a)

Connectable (Shared Chanout a) (Chanin a)

(Connectable al ar, Connectable bl br) => Connectable (al, bl) (ar, br)

Connectable (Enrolled PhasedBarrier ()) (Enrolled PhasedBarrier ())

Connectable (Shared Chanin a) (Shared Chanout a)

Connectable (Shared Chanout a) (Shared Chanin a)

Connectable l r => Connectable (ChannelPair l r) (ChannelPair l r)

(Connectable al ar, Connectable bl br, Connectable cl cr) => Connectable (al, bl, cl) (ar, br, cr)

(Connectable al ar, Connectable bl br, Connectable cl cr, Connectable dl dr) => Connectable (al, bl, cl, dl) (ar, br, cr, dr)

(Connectable al ar, Connectable bl br, Connectable cl cr, Connectable dl dr, Connectable el er) => Connectable (al, bl, cl, dl, el) (ar, br, cr, dr, er)

(<=>) :: Connectable l r => (a -> l -> CHP ()) -> (r -> b -> CHP ()) -> a -> b -> CHP ()

Joins together the given two processes and runs them in parallel.

(|<=>) :: Connectable l r => (l -> CHP ()) -> (r -> b -> CHP ()) -> b -> CHP ()

Joins together the given two processes and runs them in parallel.

(<=>|) :: Connectable l r => (a -> l -> CHP ()) -> (r -> CHP ()) -> a -> CHP ()

Joins together the given two processes and runs them in parallel.

(|<=>|) :: Connectable l r => (l -> CHP ()) -> (r -> CHP ()) -> CHP ()

Joins together the given two processes and runs them in parallel.

pipelineConnect :: Connectable l r => [r -> l -> CHP ()] -> r -> l -> CHP ()

Like foldl1 (=); connects a pipeline of processes together. If the list is empty, it returns a process that ignores both its arguments and returns instantly.

pipelineConnectComplete :: Connectable l r => (l -> CHP ()) -> [r -> l -> CHP ()] -> (r -> CHP ()) -> CHP ()

Connects the given beginning process, the list of middle processes, and the end process into a pipeline and runs them all in parallel. If the list is empty, it connects the beginning directly to the end.

cycleConnect :: Connectable l r => [r -> l -> CHP ()] -> CHP ()

Like pipelineConnect but also connects the last process into the first. If the list is empty, it returns immediately.

connectList :: Connectable l r => Int -> ([(l, r)] -> CHP a) -> CHP a

Like connect, but provides the process a list of items of the specified size, and runs it.

connectList_ :: Connectable l r => Int -> ([(l, r)] -> CHP a) -> CHP ()

Like connectList but ignores the results.

data ChannelPair l r

A pair of channels. The main use of this type is with the Connectable class, as it allows you to wire together two processes that take the exact same channel pair, e.g. both are of type ChannelPair (Chanin Int) (Chanout Int) -> CHP (). With the normal Connectable pair instances, one would need to be of type (Chanin Int, Chanout Int) -> CHP (), and the other of type (Chanout Int, Chanin Int) -> CHP ().

Instances

(Eq l, Eq r) => Eq (ChannelPair l r)

(Show l, Show r) => Show (ChannelPair l r)

Connectable l r => Connectable (ChannelPair l r) (ChannelPair l r)

class ConnectableExtra l r where

Like Connectable, but allows an extra parameter.

The API (and name) for this is still in flux, so do not rely on it just yet.

Associated Types

type ConnectableParam l r

Methods

connectExtra :: ConnectableParam l r -> ((l, r) -> CHP ()) -> CHP ()

Runs the given code with the two items connected.

Instances

ConnectableExtra (Chanin a) (Chanout a)

ConnectableExtra (Chanout a) (Chanin a)

ConnectableExtra (Chanin a) (Shared Chanout a)

ConnectableExtra (Chanout a) (Shared Chanin a)

ConnectableExtra (Shared Chanin a) (Chanout a)

ConnectableExtra (Shared Chanout a) (Chanin a)

(ConnectableExtra al ar, ConnectableExtra bl br) => ConnectableExtra (al, bl) (ar, br)

ConnectableExtra (Enrolled PhasedBarrier ph) (Enrolled PhasedBarrier ph)

ConnectableExtra (Shared Chanin a) (Shared Chanout a)

ConnectableExtra (Shared Chanout a) (Shared Chanin a)

(ConnectableExtra al ar, ConnectableExtra bl br, ConnectableExtra cl cr) => ConnectableExtra (al, bl, cl) (ar, br, cr)

(ConnectableExtra al ar, ConnectableExtra bl br, ConnectableExtra cl cr, ConnectableExtra dl dr) => ConnectableExtra (al, bl, cl, dl) (ar, br, cr, dr)

(ConnectableExtra al ar, ConnectableExtra bl br, ConnectableExtra cl cr, ConnectableExtra dl dr, ConnectableExtra el er) => ConnectableExtra (al, bl, cl, dl, el) (ar, br, cr, dr, er)

connectWith :: ConnectableExtra l r => ConnectableParam l r -> (a -> l -> CHP ()) -> (r -> b -> CHP ()) -> a -> b -> CHP ()

Like '(=)' but with ConnectableExtra