Modulelifted-async-0.11.0

Control.Concurrent.Async.Lifted.Safe

Synopsis

value compareAsyncs
value pollSTM
value waitAnyCatchSTM
value waitAnySTM
value waitBothSTM
value waitCatchSTM
value waitEitherCatchSTM
value waitEitherSTM
value waitEitherSTM_
value waitSTM
value link
value link2
value async
value asyncBound
value asyncOn
value asyncOnWithUnmask
value asyncWithUnmask
value cancel
value cancelWith
value concurrently
value concurrently_
value forConcurrently
value forConcurrently_
value mapConcurrently
value mapConcurrently_
value poll
value race
value race_
value replicateConcurrently
value replicateConcurrently_
value uninterruptibleCancel
value wait
value waitAny
value waitAnyCancel
value waitAnyCatch
value waitAnyCatchCancel
value waitBoth
value waitCatch
value waitEither
value waitEitherCancel
value waitEitherCatch
value waitEitherCatchCancel
value waitEither_
value withAsync
value withAsyncBound
value withAsyncOn
value withAsyncOnWithUnmask
value withAsyncWithUnmask
data Async
value asyncThreadId
data AsyncCancelled
data ExceptionInLinkedThread
class Forall
data Concurrently
class Pure

Packagelifted-async-0.11.0
Exports55
LicenceBSD-3-Clause

valuecompareAsyncs :: Async a -> Async b -> Ordering

valuepollSTM :: Async a -> STM (Maybe (Either SomeException a))

valuewaitAnyCatchSTM :: [Async a] -> STM (Async a, Either SomeException a)

valuewaitAnySTM :: [Async a] -> STM (Async a, a)

valuewaitBothSTM :: Async a -> Async b -> STM (a, b)

valuewaitCatchSTM :: Async a -> STM (Either SomeException a)

valuewaitEitherCatchSTM

:: Async a
-> Async b
-> STM (Either (Either SomeException a) (Either SomeException b))

valuewaitEitherSTM :: Async a -> Async b -> STM (Either a b)

valuewaitEitherSTM_ :: Async a -> Async b -> STM ()

valuewaitSTM :: Async a -> STM a

valuelink :: MonadBase IO m => Async a -> m ()

valuelink2 :: MonadBase IO m => Async a -> Async b -> m ()

valueasync :: (MonadBaseControl IO m, Forall (Pure m)) => m a -> m (Async a)

valueasyncBound :: (MonadBaseControl IO m, Forall (Pure m)) => m a -> m (Async a)

valueasyncOn

:: (MonadBaseControl IO m, Forall (Pure m))
=> Int
-> m a
-> m (Async a)

valueasyncOnWithUnmask

:: (MonadBaseControl IO m, Forall (Pure m))
=> Int
-> (forall b. m b -> m b) -> m a
-> m (Async a)

valueasyncWithUnmask

:: (MonadBaseControl IO m, Forall (Pure m))
=> (forall b. m b -> m b) -> m a
-> m (Async a)

valuecancel :: MonadBase IO m => Async a -> m ()

valuecancelWith :: (MonadBase IO m, Exception e) => Async a -> e -> m ()

valueconcurrently

:: (MonadBaseControl IO m, Forall (Pure m))
=> m a
-> m b
-> m (a, b)

valueconcurrently_

:: (MonadBaseControl IO m, Forall (Pure m))
=> m a
-> m b
-> m ()

valueforConcurrently

:: (Traversable t, MonadBaseControl IO m, Forall (Pure m))
=> t a
-> a -> m b
-> m (t b)

valueforConcurrently_

:: (Foldable t, MonadBaseControl IO m, Forall (Pure m))
=> t a
-> a -> m b
-> m ()

valuemapConcurrently

:: (Traversable t, MonadBaseControl IO m, Forall (Pure m))
=> a -> m b
-> t a
-> m (t b)

valuemapConcurrently_

:: (Foldable t, MonadBaseControl IO m, Forall (Pure m))
=> a -> m b
-> t a
-> m ()

valuepoll

:: (MonadBase IO m, Forall (Pure m))
=> Async a
-> m (Maybe (Either SomeException a))

valuerace

:: (MonadBaseControl IO m, Forall (Pure m))
=> m a
-> m b
-> m (Either a b)

valuerace_ :: (MonadBaseControl IO m, Forall (Pure m)) => m a -> m b -> m ()

valuereplicateConcurrently

:: (MonadBaseControl IO m, Forall (Pure m))
=> Int
-> m a
-> m [a]

valuereplicateConcurrently_

:: (MonadBaseControl IO m, Forall (Pure m))
=> Int
-> m a
-> m ()

valueuninterruptibleCancel :: MonadBase IO m => Async a -> m ()

valuewait :: (MonadBase IO m, Forall (Pure m)) => Async a -> m a

valuewaitAny :: (MonadBase IO m, Forall (Pure m)) => [Async a] -> m (Async a, a)

valuewaitAnyCancel

:: (MonadBase IO m, Forall (Pure m))
=> [Async a]
-> m (Async a, a)

valuewaitAnyCatch

:: (MonadBase IO m, Forall (Pure m))
=> [Async a]
-> m (Async a, Either SomeException a)

valuewaitAnyCatchCancel

:: (MonadBase IO m, Forall (Pure m))
=> [Async a]
-> m (Async a, Either SomeException a)

valuewaitBoth

:: (MonadBase IO m, Forall (Pure m))
=> Async a
-> Async b
-> m (a, b)

valuewaitCatch

:: (MonadBase IO m, Forall (Pure m))
=> Async a
-> m (Either SomeException a)

valuewaitEither

:: (MonadBase IO m, Forall (Pure m))
=> Async a
-> Async b
-> m (Either a b)

valuewaitEitherCancel

:: (MonadBase IO m, Forall (Pure m))
=> Async a
-> Async b
-> m (Either a b)

valuewaitEitherCatch

:: (MonadBase IO m, Forall (Pure m))
=> Async a
-> Async b
-> m (Either (Either SomeException a) (Either SomeException b))

valuewaitEitherCatchCancel

:: (MonadBase IO m, Forall (Pure m))
=> Async a
-> Async b
-> m (Either (Either SomeException a) (Either SomeException b))

valuewaitEither_ :: MonadBase IO m => Async a -> Async b -> m ()

valuewithAsync

:: (MonadBaseControl IO m, Forall (Pure m))
=> m a
-> Async a -> m b
-> m b

valuewithAsyncBound

:: (MonadBaseControl IO m, Forall (Pure m))
=> m a
-> Async a -> m b
-> m b

valuewithAsyncOn

:: (MonadBaseControl IO m, Forall (Pure m))
=> Int
-> m a
-> Async a -> m b
-> m b

valuewithAsyncOnWithUnmask

:: (MonadBaseControl IO m, Forall (Pure m))
=> Int
-> (forall c. m c -> m c) -> m a
-> Async a -> m b
-> m b

valuewithAsyncWithUnmask

:: (MonadBaseControl IO m, Forall (Pure m))
=> (forall c. m c -> m c) -> m a
-> Async a -> m b
-> m b

datadata Async a

Instances4Functor, Eq, Ord, Hashable

Functor AsyncDefined in async-2.2.6 · Control.Concurrent.Async.Internal
Eq (Async a)Defined in async-2.2.6 · Control.Concurrent.Async.Internal
Ord (Async a)Defined in async-2.2.6 · Control.Concurrent.Async.Internal
Hashable (Async a)Defined in async-2.2.6 · Control.Concurrent.Async.Internal

valueasyncThreadId :: Async a -> ThreadId

datadata AsyncCancelled

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

datadata ExceptionInLinkedThread

Constructors

forall a. ExceptionInLinkedThread (Async a) SomeException

Instances2Show, Exception

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

classclass (forall (a :: k). p a) => Forall (p :: k -> Constraint)

Instances1Forall

(forall (a :: k). p a) => Forall pDefined in constraints-0.14.4 · Data.Constraint.Forall

datadata Concurrently (m :: Type -> Type) a where

Constructors

Concurrently :: Forall (Pure m) => m a -> Concurrently m a
- runConcurrently :: m a

Instances5Functor, Applicative, Alternative, Semigroup, Monoid

Functor m => Functor (Concurrently m)Defined in lifted-async-0.11.0 · Control.Concurrent.Async.Lifted.Safe
(MonadBaseControl IO m, Forall (Pure m)) => Applicative (Concurrently m)Defined in lifted-async-0.11.0 · Control.Concurrent.Async.Lifted.Safe
(MonadBaseControl IO m, Forall (Pure m)) => Alternative (Concurrently m)Defined in lifted-async-0.11.0 · Control.Concurrent.Async.Lifted.Safe
(MonadBaseControl IO m, Semigroup a, Forall (Pure m)) => Semigroup (Concurrently m a)Defined in lifted-async-0.11.0 · Control.Concurrent.Async.Lifted.Safe
(MonadBaseControl IO m, Semigroup a, Monoid a, Forall (Pure m)) => Monoid (Concurrently m a)Defined in lifted-async-0.11.0 · Control.Concurrent.Async.Lifted.Safe

classclass StM m a ~ a => Pure (m :: Type -> Type) a

Instances1Pure

StM m a ~ a => Pure m aDefined in lifted-async-0.11.0 · Control.Concurrent.Async.Lifted.Safe