Safe Haskell	None
Language	Haskell2010

Kafka.Conduit.Combinators

Synopsis

Documentation

newtype BatchSize :: * #

Constructors

BatchSize
Fields unBatchSize :: Int

Instances

Eq BatchSize
Methods (==) :: BatchSize -> BatchSize -> Bool # (/=) :: BatchSize -> BatchSize -> Bool #
Num BatchSize
Methods (+) :: BatchSize -> BatchSize -> BatchSize # (-) :: BatchSize -> BatchSize -> BatchSize # (*) :: BatchSize -> BatchSize -> BatchSize # negate :: BatchSize -> BatchSize # abs :: BatchSize -> BatchSize # signum :: BatchSize -> BatchSize # fromInteger :: Integer -> BatchSize #
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 #
Read BatchSize
Methods readsPrec :: Int -> ReadS BatchSize # readList :: ReadS [BatchSize] # readPrec :: ReadPrec BatchSize # readListPrec :: ReadPrec [BatchSize] #
Show BatchSize
Methods showsPrec :: Int -> BatchSize -> ShowS # show :: BatchSize -> String # showList :: [BatchSize] -> ShowS #

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

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

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