Moduleio-classes-1.8.0.1

Control.Monad.Class.MonadAsync

Synopsis

value forConcurrently
value forConcurrently_
value link
value link2
value link2Only
value linkOnly
value mapConcurrently
value mapConcurrently_
value replicateConcurrently
value replicateConcurrently_
data AsyncCancelled
newtype Concurrently
data ExceptionInLinkedThread
class MonadAsync

Packageio-classes-1.8.0.1
Exports14
LicenceApache-2.0
SourceInternal.hs

valueforConcurrently

:: (Traversable t, MonadAsync m)
=> t a
-> a -> m b
-> m (t b)

valueforConcurrently_ :: (Foldable f, MonadAsync m) => f a -> (a -> m b) -> m ()

valuelink :: (MonadAsync m, MonadFork m, MonadMask m) => Async m a -> m ()

valuelink2

:: (MonadAsync m, MonadFork m, MonadMask m)
=> Async m a
-> Async m b
-> m ()

valuelink2Only

:: (MonadAsync m, MonadFork m, MonadMask m)
=> SomeException -> Bool
-> Async m a
-> Async m b
-> m ()

valuelinkOnly

:: (MonadAsync m, MonadFork m, MonadMask m)
=> SomeException -> Bool
-> Async m a
-> m ()

valuemapConcurrently

:: (Traversable t, MonadAsync m)
=> a -> m b
-> t a
-> m (t b)

valuemapConcurrently_ :: (Foldable f, MonadAsync m) => (a -> m b) -> f a -> m ()

valuereplicateConcurrently :: MonadAsync m => Int -> m a -> m [a]

valuereplicateConcurrently_ :: MonadAsync m => Int -> m a -> m ()

datadata AsyncCancelled

Source#

The exception thrown by cancel to terminate a thread.

AsyncCancelled

Instances3Eq, Show, Exception

Eq AsyncCancelledDefined in async-2.2.6 · Control.Concurrent.Async.Internal
Show AsyncCancelledDefined in async-2.2.6 · Control.Concurrent.Async.Internal
Exception AsyncCancelledDefined in async-2.2.6 · Control.Concurrent.Async.Internal

newtypenewtype Concurrently (m :: k -> Type) (a :: k)

Constructors

Concurrently
- runConcurrently :: m a

Instances5Functor, Applicative, Alternative, Semigroup, Monoid

Functor m => Functor (Concurrently m)Defined in io-classes-1.8.0.1 · Control.Monad.Class.MonadAsync
MonadAsync m => Applicative (Concurrently m)Defined in io-classes-1.8.0.1 · Control.Monad.Class.MonadAsync
(MonadAsync m, MonadTimer m) => Alternative (Concurrently m)Defined in io-classes-1.8.0.1 · Control.Monad.Class.MonadAsync
(Semigroup a, MonadAsync m) => Semigroup (Concurrently m a)Defined in io-classes-1.8.0.1 · Control.Monad.Class.MonadAsync
(Monoid a, MonadAsync m) => Monoid (Concurrently m a)Defined in io-classes-1.8.0.1 · Control.Monad.Class.MonadAsync

datadata ExceptionInLinkedThread

Constructors

ExceptionInLinkedThread String SomeException

Instances2Show, Exception

Show ExceptionInLinkedThreadDefined in io-classes-1.8.0.1 · Control.Monad.Class.MonadAsync
Exception ExceptionInLinkedThreadDefined in io-classes-1.8.0.1 · Control.Monad.Class.MonadAsync

classclass (MonadSTM m, MonadThread m) => MonadAsync (m :: Type -> Type) where

Associated types

type family Async (m :: Type -> Type) :: Type -> Type

Methods

async :: m a -> m (Async m a)
asyncBound :: m a -> m (Async m a)
asyncOn :: Int -> m a -> m (Async m a)
asyncThreadId :: Async m a -> ThreadId m
withAsync :: m a -> (Async m a -> m b) -> m b
withAsyncBound :: m a -> (Async m a -> m b) -> m b
withAsyncOn :: Int -> m a -> (Async m a -> m b) -> m b
waitSTM :: Async m a -> STM m a
pollSTM :: Async m a -> STM m (Maybe (Either SomeException a))
waitCatchSTM :: Async m a -> STM m (Either SomeException a)
waitAnySTM :: [Async m a] -> STM m (Async m a, a)
waitAnyCatchSTM :: [Async m a] -> STM m (Async m a, Either SomeException a)
waitEitherSTM :: Async m a -> Async m b -> STM m (Either a b)
waitEitherSTM_ :: Async m a -> Async m b -> STM m ()
waitEitherCatchSTM :: Async m a -> Async m b -> STM m (Either (Either SomeException a) (Either SomeException b))
waitBothSTM :: Async m a -> Async m b -> STM m (a, b)
wait :: Async m a -> m a
poll :: Async m a -> m (Maybe (Either SomeException a))
waitCatch :: Async m a -> m (Either SomeException a)
cancel :: Async m a -> m ()
cancelWith :: Exception e => Async m a -> e -> m ()
uninterruptibleCancel :: Async m a -> m ()
waitAny :: [Async m a] -> m (Async m a, a)
waitAnyCatch :: [Async m a] -> m (Async m a, Either SomeException a)
waitAnyCancel :: [Async m a] -> m (Async m a, a)
waitAnyCatchCancel :: [Async m a] -> m (Async m a, Either SomeException a)
waitEither :: Async m a -> Async m b -> m (Either a b)
waitEitherCatch :: Async m a -> Async m b -> m (Either (Either SomeException a) (Either SomeException b))
waitEitherCancel :: Async m a -> Async m b -> m (Either a b)
waitEitherCatchCancel :: Async m a -> Async m b -> m (Either (Either SomeException a) (Either SomeException b))
waitEither_ :: Async m a -> Async m b -> m ()
waitBoth :: Async m a -> Async m b -> m (a, b)
race :: m a -> m b -> m (Either a b)
race_ :: m a -> m b -> m ()
concurrently :: m a -> m b -> m (a, b)
concurrently_ :: m a -> m b -> m ()
asyncWithUnmask :: ((forall b. m b -> m b) -> m a) -> m (Async m a)
asyncOnWithUnmask :: Int -> ((forall b. m b -> m b) -> m a) -> m (Async m a)
withAsyncWithUnmask :: ((forall c. m c -> m c) -> m a) -> (Async m a -> m b) -> m b
withAsyncOnWithUnmask :: Int -> ((forall c. m c -> m c) -> m a) -> (Async m a -> m b) -> m b
compareAsyncs :: Async m a -> Async m b -> Ordering

Instances2MonadAsync

MonadAsync IODefined in io-classes-1.8.0.1 · Control.Monad.Class.MonadAsync
(MonadAsync m, MonadCatch (STM m), MonadFork m, MonadMask m) => MonadAsync (ReaderT r m)Defined in io-classes-1.8.0.1 · Control.Monad.Class.MonadAsync