Kafka.Conduit.Combinators

Documentation

newtype BatchSize

Constructors

BatchSize Int

Instances

Eq BatchSize

Methods

(==) :: BatchSize -> BatchSize -> Bool

(/=) :: BatchSize -> BatchSize -> Bool

Ord BatchSize

Methods

compare :: BatchSize -> BatchSize -> Ordering

(<) :: BatchSize -> BatchSize -> Bool

(<=) :: BatchSize -> BatchSize -> Bool

(>) :: BatchSize -> BatchSize -> Bool

(>=) :: BatchSize -> BatchSize -> Bool

max :: BatchSize -> BatchSize -> BatchSize

min :: BatchSize -> BatchSize -> BatchSize

Show BatchSize

Methods

showsPrec :: Int -> BatchSize -> ShowS

show :: BatchSize -> String

showList :: [BatchSize] -> ShowS

batchByOrFlush :: Monad m => BatchSize -> Conduit (Maybe a) m [a]

batchByOrFlushEither :: Monad m => BatchSize -> Conduit (Either e a) m [a]

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.

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

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)

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