Methods
withAsync :: HasCallStack => ShellT env m a -> (Async a -> ShellT env m b) -> ShellT env m b Source #
withAsyncBound :: HasCallStack => ShellT env m a -> (Async a -> ShellT env m b) -> ShellT env m b Source #
withAsyncOn :: HasCallStack => Int -> ShellT env m a -> (Async a -> ShellT env m b) -> ShellT env m b Source #
withAsyncWithUnmask :: HasCallStack => ((forall c. ShellT env m c -> ShellT env m c) -> ShellT env m a) -> (Async a -> ShellT env m b) -> ShellT env m b Source #
withAsyncOnWithUnmask :: HasCallStack => Int -> ((forall c. ShellT env m c -> ShellT env m c) -> ShellT env m a) -> (Async a -> ShellT env m b) -> ShellT env m b Source #
wait :: HasCallStack => Async a -> ShellT env m a Source #
poll :: HasCallStack => Async a -> ShellT env m (Maybe (Either SomeException a)) Source #
waitCatch :: HasCallStack => Async a -> ShellT env m (Either SomeException a) Source #
cancel :: HasCallStack => Async a -> ShellT env m () Source #
uninterruptibleCancel :: HasCallStack => Async a -> ShellT env m () Source #
cancelWith :: (Exception e, HasCallStack) => Async a -> e -> ShellT env m () Source #
race :: HasCallStack => ShellT env m a -> ShellT env m b -> ShellT env m (Either a b) Source #
concurrently :: HasCallStack => ShellT env m a -> ShellT env m b -> ShellT env m (a, b) Source #
concurrently_ :: HasCallStack => ShellT env m a -> ShellT env m b -> ShellT env m () Source #
waitAny :: HasCallStack => [Async a] -> ShellT env m (Async a, a) Source #
waitAnyCatch :: HasCallStack => [Async a] -> ShellT env m (Async a, Either SomeException a) Source #
waitAnyCancel :: HasCallStack => [Async a] -> ShellT env m (Async a, a) Source #
waitAnyCatchCancel :: HasCallStack => [Async a] -> ShellT env m (Async a, Either SomeException a) Source #
waitEither :: HasCallStack => Async a -> Async b -> ShellT env m (Either a b) Source #
waitEitherCatch :: HasCallStack => Async a -> Async b -> ShellT env m (Either (Either SomeException a) (Either SomeException b)) Source #
waitEitherCancel :: HasCallStack => Async a -> Async b -> ShellT env m (Either a b) Source #
waitEitherCatchCancel :: HasCallStack => Async a -> Async b -> ShellT env m (Either (Either SomeException a) (Either SomeException b)) Source #
waitEither_ :: HasCallStack => Async a -> Async b -> ShellT env m () Source #
waitBoth :: HasCallStack => Async a -> Async b -> ShellT env m (a, b) Source #
async :: HasCallStack => ShellT env m a -> ShellT env m (Async a) Source #
asyncBound :: HasCallStack => ShellT env m a -> ShellT env m (Async a) Source #
asyncOn :: HasCallStack => Int -> ShellT env m a -> ShellT env m (Async a) Source #
asyncWithUnmask :: HasCallStack => ((forall b. ShellT env m b -> ShellT env m b) -> ShellT env m a) -> ShellT env m (Async a) Source #
asyncOnWithUnmask :: HasCallStack => Int -> ((forall b. ShellT env m b -> ShellT env m b) -> ShellT env m a) -> ShellT env m (Async a) Source #
link :: HasCallStack => Async a -> ShellT env m () Source #
linkOnly :: HasCallStack => (SomeException -> Bool) -> Async a -> ShellT env m () Source #
link2 :: HasCallStack => Async a -> Async b -> ShellT env m () Source #
link2Only :: HasCallStack => (SomeException -> Bool) -> Async a -> Async b -> ShellT env m () Source #
pooledMapConcurrentlyN :: (HasCallStack, Traversable t) => Positive Int -> (a -> ShellT env m b) -> t a -> ShellT env m (t b) Source #
pooledMapConcurrently :: (HasCallStack, Traversable t) => (a -> ShellT env m b) -> t a -> ShellT env m (t b) Source #
pooledMapConcurrentlyN_ :: (Foldable f, HasCallStack) => Positive Int -> (a -> ShellT env m b) -> f a -> ShellT env m () Source #
pooledMapConcurrently_ :: (Foldable f, HasCallStack) => (a -> ShellT env m b) -> f a -> ShellT env m () Source #