Modulemachines-0.7.4Haskell2010

Data.Machine.Pipe

Allows bidirectional communication between two MachineT. Exposed the same interface of Pipes library.

8 types
11 values

Packagemachines-0.7.4
Exports19
LanguageHaskell2010
LicenceBSD-3-Clause
SourcePipe.hs

datadata Exchange a' a b' b c where

Constructors

Request :: a' -> Exchange a' a b' b a
Respond :: b -> Exchange a' a b' b b'

typetype Proxy a' a b' b (m :: Type -> Type) c = MachineT m (Exchange a' a b' b) c

typetype Effect (m :: Type -> Type) r = Proxy Void () () Void m r

Effects neither request nor respond

typetype Client a' a (m :: Type -> Type) r = Proxy a' a () Void m r

Client a' a sends requests of type a' and receives responses of type a. Clients only request and never respond.

typetype Server b' b (m :: Type -> Type) r = Proxy Void () b' b m r

Server b' b receives requests of type b' and sends responses of type b. Servers only respond and never request.

typetype Effect' (m :: Type -> Type) r = forall x' x y' y. Proxy x' x y' y m r

Like Effect, but with a polymorphic type

typetype Server' b' b (m :: Type -> Type) r = forall x' x. Proxy x' x b' b m r

Like Server, but with a polymorphic type

typetype Client' a' a (m :: Type -> Type) r = forall y' y. Proxy a' a y' y m r

Like Client, but with a polymorphic type

valuerequest :: a' -> PlanT (Exchange a' a y' y) o m a

Send a value of type a' upstream and block waiting for a reply of type a. request is the identity of the request category.

valuerespond :: a -> PlanT (Exchange x' x a' a) o m a'

Send a value of type a downstream and block waiting for a reply of type a' respond is the identity of the respond category.

valuepush :: Monad m => a -> Proxy a' a a' a m r

Forward responses followed by requests. push is the identity of the push category.

value(>~>)

:: Monad m
=> _a -> Proxy a' a b' b m r
-> b -> Proxy b' b c' c m r
-> _a
-> Proxy a' a c' c m r

Compose two proxies blocked while requesting data, creating a new proxy blocked while requesting data. (>~>) is the composition operator of the push category.

value(>>~)

:: Monad m
=> Proxy a' a b' b m r
-> b -> Proxy b' b c' c m r
-> Proxy a' a c' c m r

(p >>~ f) pairs each respond in p with an request in f.

valuepull :: Monad m => a' -> Proxy a' a a' a m r

Forward requests followed by responses. pull is the identity of the pull category.

value(>+>)

:: Monad m
=> b' -> Proxy a' a b' b m r
-> _c' -> Proxy b' b c' c m r
-> _c'
-> Proxy a' a c' c m r

Compose two proxies blocked in the middle of responding, creating a new proxy blocked in the middle of responding. (>+>) is the composition operator of the pull category.

value(+>>)

:: Monad m
=> b' -> Proxy a' a b' b m r
-> Proxy b' b c' c m r
-> Proxy a' a c' c m r

(f +>> p) pairs each request in p with a respond in f.

valueabsurdExchange :: Exchange Void a b Void t -> c

It is impossible for an Exchange to hold a Void value.

valuerunEffect :: Monad m => Effect m o -> m [o]

Run a self-contained Effect, converting it back to the base monad.

valuerunEffect_ :: Monad m => Effect m o -> m ()

Like runEffect but discarding any produced value.