diff --git a/src/Quasar/Async.hs b/src/Quasar/Async.hs index 42d892c61b679500c71889e45258c6126fc9af20..e0fd507ed9297db939fe438fd1568ec7500e9092 100644 --- a/src/Quasar/Async.hs +++ b/src/Quasar/Async.hs @@ -97,6 +97,8 @@ instance MonadAsync UnlimitedAsync where liftIO $ unmask $ runReaderT action resourceManager +-- | Run a computation in `MonadAsync` where `async` is implemented without any thread limits (i.e. every `async` will +-- fork a new (RTS) thread). runUnlimitedAsync :: (MonadResourceManager m) => (forall f. MonadAsync f => f r) -> m r runUnlimitedAsync action = do resourceManager <- askResourceManager