Allow tasks to run concurrently

PREreview · Dec 6, 2023 · 66c1f86 · 66c1f86
1 parent 08ce403
commit 66c1f86
Showing 1 changed file with 11 additions and 8 deletions.
diff --git a/src/Program.ts b/src/Program.ts
@@ -78,14 +78,17 @@ const processUser = (user: Users.User) =>
     }
 
     yield* _(
-      Effect.forEach(
-        decisions,
-        Match.valueTags({
-          AddReviewToProfile: decision =>
-            Effect.logWarning('Need to add review').pipe(Effect.annotateLogs('doi', decision.doi)),
-          RemoveReviewFromProfile: decision =>
-            Effect.logWarning('Need to remove review').pipe(Effect.annotateLogs('doi', decision.doi)),
-        }),
+      Effect.all(
+        ReadonlyArray.map(
+          decisions,
+          Match.valueTags({
+            AddReviewToProfile: decision =>
+              Effect.logWarning('Need to add review').pipe(Effect.annotateLogs('doi', decision.doi)),
+            RemoveReviewFromProfile: decision =>
+              Effect.logWarning('Need to remove review').pipe(Effect.annotateLogs('doi', decision.doi)),
+          }),
+        ),
+        { concurrency: 'inherit' },
       ),
     )
   }).pipe(