UnliftIO.Async

Contents

• Asynchronous actions
  • Spawning
  • Spawning with automatic cancelation
  • Querying Asyncs
  • STM operations
  • Waiting for multiple Asyncs
  • Waiting for multiple Asyncs in STM
  • Linking
• Convenient utilities

Description

Synopsis

• data Async a :: * -> *
• async :: MonadUnliftIO m => m a -> m (Async a)
• asyncBound :: MonadUnliftIO m => m a -> m (Async a)
• asyncOn :: MonadUnliftIO m => Int -> m a -> m (Async a)
• asyncWithUnmask :: MonadUnliftIO m => ((forall b. m b -> m b) -> m a) -> m (Async a)
• asyncOnWithUnmask :: MonadUnliftIO m => Int -> ((forall b. m b -> m b) -> m a) -> m (Async a)
• withAsync :: MonadUnliftIO m => m a -> (Async a -> m b) -> m b
• withAsyncBound :: MonadUnliftIO m => m a -> (Async a -> m b) -> m b
• withAsyncOn :: MonadUnliftIO m => Int -> m a -> (Async a -> m b) -> m b
• withAsyncWithUnmask :: MonadUnliftIO m => ((forall c. m c -> m c) -> m a) -> (Async a -> m b) -> m b
• withAsyncOnWithUnmask :: MonadUnliftIO m => Int -> ((forall c. m c -> m c) -> m a) -> (Async a -> m b) -> m b
• wait :: MonadIO m => Async a -> m a
• poll :: MonadIO m => Async a -> m (Maybe (Either SomeException a))
• waitCatch :: MonadIO m => Async a -> m (Either SomeException a)
• cancel :: MonadIO m => Async a -> m ()
• uninterruptibleCancel :: MonadIO m => Async a -> m ()
• cancelWith :: (Exception e, MonadIO m) => Async a -> e -> m ()
• asyncThreadId :: Async a -> ThreadId
• waitSTM :: Async a -> STM a
• pollSTM :: Async a -> STM (Maybe (Either SomeException a))
• waitCatchSTM :: Async a -> STM (Either SomeException a)
• waitAny :: MonadIO m => [Async a] -> m (Async a, a)
• waitAnyCatch :: MonadIO m => [Async a] -> m (Async a, Either SomeException a)
• waitAnyCancel :: MonadIO m => [Async a] -> m (Async a, a)
• waitAnyCatchCancel :: MonadIO m => [Async a] -> m (Async a, Either SomeException a)
• waitEither :: MonadIO m => Async a -> Async b -> m (Either a b)
• waitEitherCatch :: MonadIO m => Async a -> Async b -> m (Either (Either SomeException a) (Either SomeException b))
• waitEitherCancel :: MonadIO m => Async a -> Async b -> m (Either a b)
• waitEitherCatchCancel :: MonadIO m => Async a -> Async b -> m (Either (Either SomeException a) (Either SomeException b))
• waitEither_ :: MonadIO m => Async a -> Async b -> m ()
• waitBoth :: MonadIO m => Async a -> Async b -> m (a, b)
• waitAnySTM :: [Async a] -> STM (Async a, a)
• waitAnyCatchSTM :: [Async a] -> STM (Async a, Either SomeException a)
• waitEitherSTM :: Async a -> Async b -> STM (Either a b)
• waitEitherCatchSTM :: Async a -> Async b -> STM (Either (Either SomeException a) (Either SomeException b))
• waitEitherSTM_ :: Async a -> Async b -> STM ()
• waitBothSTM :: Async a -> Async b -> STM (a, b)
• link :: MonadIO m => Async a -> m ()
• link2 :: MonadIO m => Async a -> Async b -> m ()
• race :: MonadUnliftIO m => m a -> m b -> m (Either a b)
• race_ :: MonadUnliftIO m => m a -> m b -> m ()
• concurrently :: MonadUnliftIO m => m a -> m b -> m (a, b)
• concurrently_ :: MonadUnliftIO m => m a -> m b -> m ()
• mapConcurrently :: MonadUnliftIO m => Traversable t => (a -> m b) -> t a -> m (t b)
• forConcurrently :: MonadUnliftIO m => Traversable t => t a -> (a -> m b) -> m (t b)
• mapConcurrently_ :: MonadUnliftIO m => Foldable f => (a -> m b) -> f a -> m ()
• forConcurrently_ :: MonadUnliftIO m => Foldable f => f a -> (a -> m b) -> m ()
• replicateConcurrently :: MonadUnliftIO m => Int -> m a -> m [a]
• replicateConcurrently_ :: MonadUnliftIO m => Int -> m a -> m ()
• newtype Concurrently m a = Concurrently {
  • runConcurrently :: m a
  }

Asynchronous actions

Spawning

Spawning with automatic cancelation

Querying Asyncs

STM operations

Waiting for multiple Asyncs

Waiting for multiple Asyncs in STM

Linking

Convenient utilities