hw-kafka-conduit-2.1.0: Conduit bindings for hw-kafka-client

Safe HaskellSafe
LanguageHaskell2010

Kafka.Conduit.Combinators

Synopsis

Documentation

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

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.

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

Throws the left part of a value in a MonadThrow context

throwLeftSatisfy :: (MonadThrow m, Exception e) => (e -> Bool) -> Conduit (Either e i) m (Either e i) Source #

Throws the left part of a value in a MonadThrow context if the value satisfies the predicate