github/semantic
1
1
Fork 0
mirror of https://github.com/github/semantic.git synced 2024-12-29 18:06:14 +03:00
Code Issues Projects Releases Wiki Activity

Revert "Add a Distribute handler taking a handler for monad transformers wrapping IO."

Browse Source 
This reverts commit f9f69104e2df65e014cec182e57747436356460a.
This commit is contained in:
Rob Rix 2018-08-03 13:08:41 -04:00
parent 09e1c63d88
commit e1708d6dfb
1 changed files with 1 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/Semantic/Distribute.hs
View File

@ -1,11 +1,10 @@
{-# LANGUAGE RankNTypes, ScopedTypeVariables, TypeOperators #-}
{-# LANGUAGE TypeOperators #-}
module Semantic.Distribute
( distribute
, distributeFor
, distributeFoldMap
, Distribute
, runDistribute
, runDistributeWithHandler
) where
import qualified Control.Concurrent.Async as Async
@ -44,12 +43,3 @@ instance Effect Distribute where
-- | Evaluate a 'Distribute' effect concurrently.
runDistribute :: Eff '[Distribute, Lift IO] a -> Eff '[Lift IO] a
runDistribute = interpret (\ (Distribute task) -> liftIO (Async.runConcurrently (Async.Concurrently (runM (runDistribute task)))))
-- | Evaluate a 'Distribute' effect concurrently, using a handler to lower the final monad into 'IO'.
runDistributeWithHandler :: forall m a . MonadIO m => (forall x . m x -> IO x) -> Eff '[Distribute, Lift m] a -> Eff '[Lift m] a
runDistributeWithHandler handler = interpret $ \ (Distribute task) ->
sendIO (liftIO @m (Async.runConcurrently (Async.Concurrently (handler (runM (runDistributeWithHandler handler task))))))
sendIO :: (Member (Lift m) effects) => m a -> Eff effects a
sendIO = send . Lift