Cont package:streamly

Continuation style utilities.

contListMap :: (a -> (b -> r) -> r) -> ([b] -> (c -> r) -> r) -> [a] -> (c -> r) -> r

Given a continuation based transformation from a to b and a continuation based transformation from [b] to c, make continuation based transformation from [a] to c. Pre-release

workerRateControl :: Limit -> IORef Int -> YieldRateInfo -> WorkerInfo -> IO Bool

streamly Streamly.Internal.Data.Channel

CAUTION! this also updates the yield count and therefore should be called only when we are actually yielding an element.

workerRateControl :: SVar t m a -> YieldRateInfo -> WorkerInfo -> IO Bool

streamly Streamly.Internal.Data.SVar

foldContinue :: Monad m => Fold m a b -> SerialT m a -> Fold m a b

streamly Streamly.Internal.Data.Stream.IsStream

We can create higher order folds using foldContinue. We can fold a number of streams to a given fold efficiently with full stream fusion. For example, to fold a list of streams on the same sum fold:

concatFold = Prelude.foldl Stream.foldContinue Fold.sum

fold f = Fold.extractM . Stream.foldContinue f

Internal