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 :: forall (t :: (Type -> Type) -> Type -> Type) (m :: Type -> Type) a . SVar t m a -> YieldRateInfo -> WorkerInfo -> IO Bool

streamly Streamly.Internal.Data.SVar

foldContinue :: forall (m :: Type -> Type) a b . 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