Data.Conduit.Extra.Pipes

Provides a convenience layer on top of conduit with functions and operators similar to the pipes library.

Documentation

(>->) :: forall a b i o m. Monad m => ConduitM i a m () -> ConduitM a o m b -> ConduitM i o m b

The conduit composition operator, ala pipes. When combined with runPipe (or runEffect, if you prefer), this is the only operator needed.

(<-<) :: forall a b i o m. Monad m => ConduitM a o m b -> ConduitM i a m () -> ConduitM i o m b

runPipe :: forall m b. Monad m => ConduitM () Void m b -> m b

Run a conduit. This name may be preferable to the overly generic runEffect, which pipes uses.

runPipeR :: forall m b. (MonadBaseControl IO m, Monad m) => ConduitM () Void (ResourceT m) b -> m b

Like runPipe, except implies a call to runResourceT, for running resource-sensitive pipelines.

runEffect :: forall m b. Monad m => ConduitM () Void m b -> m b

forP :: Monad m => Source m a -> (a -> m ()) -> m ()

Iterate over all the elements from source, similar to forM for a monad.

each :: (Monad m, Foldable f) => f a -> Producer m a

Call yield for each element of the Foldable data structure, resulting in a Producer over these elements.

>>> runPipe $ forP (each [1..3]) $ liftIO . print
1
2
3

take :: Monad m => Int -> Conduit a m a

Take N items from a conduit. Synonym for Conduit's isolate.

peel :: Monad m => Int -> m [()]

Peel off N items from a conduit and return them. Synonym for Conduit's take.

replicateM :: Monad m => Int -> m a -> Producer m a

Replicate a monadic action a given number of times via a producer.

tee :: Monad m => Sink a (ConduitM a a m) b -> ConduitM a a m b

Injects a sink within a pipeline which receives a copy of every input argument, similar to the Unix command of the same name.

>>> runPipe $ each [1..3] >-> tee (P.mapM_ f) >-> P.mapM_ f
1
1
2
2
3
3