lifetimes-0.2.0.1: src/Lifetimes/Async.hs

-- | Module: Lifetimes.Async
-- Description: Lifteimes integration for the async package.
module Lifetimes.Async (acquireAsync) where

import Control.Concurrent.Async (Async, async, cancel, waitCatch)
import Lifetimes
import Zhp

-- | Spawn an async task. When it is time to reclaim the resource, 'cancel'
-- will be called, and the task will be waited on.
acquireAsync :: IO a -> Acquire (Async a)
acquireAsync io = mkAcquire (async io) (\a -> cancel a <* waitCatch a)