transient-0.5.1: Making composable programs with multithreading, events and distributed computing

Safe HaskellNone
LanguageHaskell2010

Transient.Indeterminism

Description

Synopsis

Documentation

choose :: Show a => [a] -> TransIO a Source #

slurp a list of values and process them in parallel . To limit the number of processing threads, use threads

choose' :: [a] -> TransIO a Source #

alternative definition with more parallelism, as the composition of n async sentences

collect' :: Int -> Int -> TransIO a -> TransIO [a] Source #

search with a timeout After the the timeout, it stop unconditionally and return the current results. It also stops as soon as there are enough results specified in the first parameter.

group :: Int -> TransIO a -> TransIO [a] Source #

group the output of a possible multithreaded process in groups of n elements.

groupByTime :: Integer -> TransIO a -> TransIO [a] Source #

group result for a time interval, measured with diffUTCTime