Data.Conduit.Misc

Documentation

concat :: Monad m => Conduit [a] m a

Converts a stream of lists into a stream of single elements.

concatFlush :: Monad m => Integer -> Conduit [a] m (Flush a)

Converts a stream of [a] into a stream of (Flush a). This is done by sending a Flush when the input is the empty list, or that we reached a certain threshold

groupFlush :: Monad m => Conduit (Flush a) m [a]

Regroup a stream of (Flush a) into a stream of lists, using Flush as the separator

mchunk :: b -> (a -> b) -> Flush a -> b

Analogous to maybe, but for chunks

mapFlushMaybe :: Monad m => (a -> Maybe b) -> Conduit (Flush a) m (Flush b)

Like mapMaybe, but in a Flush. Will not touch the Flush values.