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 :: Monoidal (-->) (-->) (:*:) (:*:) 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 o t. Monoidal (-->) (-->) (:*:) (:*:) t => Pipeline i e t () () -> Pipeline e o t () () -> Pipeline i o t () ()

Compose two pipelines into one

pipeline :: Monoidal (-->) (-->) (:*:) (:*:) t => Pipeline i o t () () -> t ()

Run pipeline and get result