| Safe Haskell | Safe-Inferred |
|---|
Control.Concurrent.Async.Extra
- sequencePool :: Traversable t => Int -> t (IO a) -> IO (t a)
- mapPool :: Traversable t => Int -> (a -> IO b) -> t a -> IO (t b)
- sequenceConcurrently :: Traversable t => t (IO a) -> IO (t a)
- fixAsync :: (Async a -> IO a) -> IO (Async a)
- fixAsyncBound :: (Async a -> IO a) -> IO (Async a)
- fixAsyncOn :: Int -> (Async a -> IO a) -> IO (Async a)
- fixAsyncWithUnmask :: (Async a -> (forall b. IO b -> IO b) -> IO a) -> IO (Async a)
- fixAsyncOnWithUnmask :: Int -> (Async a -> (forall b. IO b -> IO b) -> IO a) -> IO (Async a)
- withParent :: Async a -> IO b -> IO (Async b)
- newtype Promise a = Promise {}
Documentation
sequencePool :: Traversable t => Int -> t (IO a) -> IO (t a)Source
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)Source
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)Source
fixAsyncWithUnmask :: (Async a -> (forall b. IO b -> IO b) -> IO a) -> IO (Async a)Source
Like fixAsync but using forkIOWithUnmask internally.
The child thread is passed a function that can be used to unmask asynchronous exceptions.
fixAsyncOnWithUnmask :: Int -> (Async a -> (forall b. IO b -> IO b) -> IO a) -> IO (Async a)Source
Like fixAsyncOn but using forkOnWithUnmask internally.
The child thread is passed a function that can be used to unmask asynchronous exceptions.