Control.Concurrent.Async.Extra

Documentation

sequencePool :: Traversable t => Int -> t (IO a) -> IO (t a)

Implementation derived from Petr Pudlák's answer on StackOverflow http://stackoverflow.com/a/18898822/230050

mapPool :: Traversable t => Int -> (a -> IO b) -> t a -> IO (t b)

Implementation copied from Petr Pudlák's answer on StackOverflow http://stackoverflow.com/a/18898822/230050

sequenceConcurrently :: Traversable t => t (IO a) -> IO (t a)

fixAsync :: (Async a -> IO a) -> IO (Async a)

Create an Async and pass it to itself.

withParent :: Async a -> IO b -> IO (Async b)

Create an async that is linked to a parent. If the parent dies so does this async

newtype Promise a

Promise is like Concurrently but includes a sequential monad instance

Constructors

Promise

Fields

unPromise :: IO a

Instances

Monad Promise

Functor Promise

MonadPlus Promise

Applicative Promise

Alternative Promise