1
1
mirror of https://github.com/github/semantic.git synced 2024-12-22 14:21:31 +03:00

🔥 parBitraversable.

This commit is contained in:
Rob Rix 2018-04-05 10:09:12 -04:00
parent de297d6fd2
commit 43b0d43168

View File

@ -36,9 +36,6 @@ runDistribute :: Members '[Exc SomeException, IO] effs => Eff (Distribute task '
runDistribute m action = interpret (\ (Distribute tasks) ->
liftIO (Async.mapConcurrently (runAction action) tasks) >>= either throwError pure . sequenceA . withStrategy (parTraversable (parTraversable rseq))) m
parBitraversable :: Bitraversable t => Strategy a -> Strategy b -> Strategy (t a b)
parBitraversable strat1 strat2 = bitraverse (rparWith strat1) (rparWith strat2)
-- | An action evaluating @task@s to some output in 'IO', or failing with an exception.
--