Moduleasync-2.2.6Haskell2010

Control.Concurrent.Stream

Processing streams with a fixed number of worker threads

Synopsis

value stream
value streamBound
value streamWithInput
value streamWithOutput
value streamWithInputOutput
value mapConcurrentlyBounded
value forConcurrentlyBounded

Packageasync-2.2.6
Exports7
LanguageHaskell2010
LicenceBSD-3-Clause
SourceStream.hs

valuestream

:: Int
Maximum Concurrency
-> ((a -> IO ()) -> IO ())
Producer
-> (a -> IO ())
Worker
-> IO ()

Maps a fixed number of workers concurrently over a stream of values produced by a producer function. The producer is passed a function to call for each work item. If a worker throws a synchronous exception, it will be propagated to the caller.

valuestreamBound

:: Int
Maximum Concurrency
-> ((a -> IO ()) -> IO ())
Producer
-> (a -> IO ())
Worker
-> IO ()

Source#

Like stream, but uses bound threads for the workers. See forkOS for details on bound threads.

valuestreamWithInput

:: ((a -> IO ()) -> IO ())
Producer
-> [b]
Worker state
-> (b -> a -> IO ())
Worker
-> IO ()

Source#

Like stream, but each worker is passed an element of an input list.

valuestreamWithOutput

:: Int
-> ((a -> IO ()) -> IO ())
Producer
-> (a -> IO c)
Worker
-> IO [c]

Source#

Like stream, but collects the results of each worker

valuestreamWithInputOutput

:: ((a -> IO ()) -> IO ())
Producer
-> [b]
Worker input
-> (b -> a -> IO c)
Worker
-> IO [c]

Source#

Like streamWithInput, but collects the results of each worker

valuemapConcurrentlyBounded

:: Int
Maximum concurrency
-> (a -> IO b)
Function to map over the input values
-> [a]
List of input values
-> IO [b]
List of output values

Source#

Concurrent map over a list of values, using a bounded number of threads.

valueforConcurrentlyBounded

:: Int
Maximum concurrency
-> [a]
List of input values
-> (a -> IO b)
Function to map over the input values
-> IO [b]
List of output values

Source#

mapConcurrentlyBounded but with its arguments reversed