Pandora.Paradigm.Controlflow.Pipeline

Documentation

type Pipeline i o t a r = Continuation r (Pipe i o r t) a

await :: Pipeline i o t i r

Take incoming value from pipeline

yield :: o -> Pipeline i o t () r

Give a value to the future consuming

finish :: Pointable t => Pipeline i o t () ()

Pipeline that does nothing

impact :: Bindable t => t a -> Pipeline i o t a a

Do some effectful computation within pipeline

(=*=) :: forall i e a o t. Pointable t => Pipeline i e t () () -> Pipeline e o t () () -> Pipeline i o t a ()

Compose two pipelines into one

pipeline :: Pointable t => Pipeline i o t r r -> t r

Run pipeline and get result