Control.Pipeline

Documentation

type Pipeline i o t a r = ContT 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 :: Monad t => Pipeline i o t () ()

Pipeline that does nothing

impact :: Monad t => t a -> Pipeline i o t a ()

Do some effectful computation within pipeline

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

Compose two pipelines into one

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

Run pipeline and get result