streamly-0.9.0: Streaming, dataflow programming and declarative concurrency
Copyright(c) 2022 Composewell Technologies
Safe HaskellSafe-Inferred





data Channel m a b Source #


data Config Source #

An abstract type for specifying the configuration parameters of a Channel. Use Config -> Config modifier functions to modify the default configuration. See the individual modifier documentation for default values.

maxBuffer :: Int -> Config -> Config Source #

Specify the maximum size of the buffer for storing the results from concurrent computations. If the buffer becomes full we stop spawning more concurrent tasks until there is space in the buffer. A value of 0 resets the buffer size to default, a negative value means there is no limit. The default value is 1500.

CAUTION! using an unbounded maxBuffer value (i.e. a negative value) coupled with an unbounded maxThreads value is a recipe for disaster in presence of infinite streams, or very large streams. Especially, it must not be used when pure is used in ZipAsyncM streams as pure in applicative zip streams generates an infinite stream causing unbounded concurrent generation with no limit on the buffer or threads.

inspect :: Bool -> Config -> Config Source #

Print debug information about the Channel when the stream ends.

Fold operations

parEval :: MonadAsync m => (Config -> Config) -> Fold m a b -> Fold m a b Source #

Evaluate the fold asynchronously in a worker thread separate from the driver thread.