@@ -76,6 +76,7 @@ import Control.Concurrent (threadDelay)
76import Control.Concurrent.Async (Async)
76import Control.Concurrent.Async (Async)
77import Control.Exception (Exception, SomeException)
77import Control.Exception (Exception, SomeException)
78import Control.Monad (forever)
78import Control.Monad (forever)
79import qualified Control.Concurrent.Async as A
80import qualified Control.Concurrent.Async as A
80import qualified UnliftIO.Async as U
81import qualified UnliftIO.Async as U
81import qualified UnliftIO.Internals.Async as I
82import qualified UnliftIO.Internals.Async as I
@@ -449,7 +450,7 @@ pooledReplicateConcurrently_ n f = unsafeEff $ \es -> do
451-- | Lifted 'U.Conc'.
452-- | Lifted 'U.Conc'.
452−data Conc es a where
453+data Conc :: [Effect] -> Type -> Type where
453 Action :: Eff es a -> Conc es a
454 Action :: Eff es a -> Conc es a
454 Apply :: Conc es (v -> a) -> Conc es v -> Conc es a
455 Apply :: Conc es (v -> a) -> Conc es v -> Conc es a
455 LiftA2 :: (x -> y -> a) -> Conc es x -> Conc es y -> Conc es a
456 LiftA2 :: (x -> y -> a) -> Conc es x -> Conc es y -> Conc es a