Safe Haskell | None |
---|---|
Language | Haskell2010 |
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