Kafka.Conduit.Utils

Documentation

throwLeft :: (MonadThrow m, Exception e) => Conduit (Either e i) m i

Throws the left part of a value in a MonadThrow context

foldYield :: Monad m => (i -> s -> (s, [o])) -> (s -> [o]) -> s -> Conduit i m o

Create a conduit that folds with the function f over its input i with its internal state s and emits outputs [o], then finally emits outputs [o] from the function g applied to the final state s.