@@ -172,10 +172,9 @@ it.effect("two concurrent uses of one ref hand the value out once", () =>
         answer: { type: "save", secret: "ghp_secret" },
       });
       const ref = Option.getOrThrow(yield* service.savedRef({ threadId, turnItemId }));
-      const results = yield* Effect.all(
-        [service.consume({ ref, projectId }), service.consume({ ref, projectId })].map(
-          Effect.result,
-        ),
+      const results = yield* Effect.forEach(
+        [service.consume({ ref, projectId }), service.consume({ ref, projectId })],
+        Effect.result,
         { concurrency: "unbounded" },
       );
       assert.deepEqual(results.map((result) => result._tag).toSorted(), ["Failure", "Success"]);
 
@@ -410,8 +410,9 @@ it.layer(NodeServices.layer)("server settings", (it) => {
     Effect.gen(function* () {
       const serverSettings = yield* ServerSettingsModule.ServerSettingsService;
       const instanceId = ProviderInstanceId.make("acpRegistry_shared");
-      const results = yield* Effect.all(
-        ["First", "Second"].map((displayName) =>
+      const results = yield* Effect.forEach(
+        ["First", "Second"],
+        (displayName) =>
           serverSettings
             .updateProviderInstance({
               operation: "create",
@@ -423,7 +424,6 @@ it.layer(NodeServices.layer)("server settings", (it) => {
               },
             })
             .pipe(Effect.result),
-        ),
         { concurrency: "unbounded" },
       );
 
 
@@ -1068,16 +1068,14 @@ it.layer(NodeServices.layer)("effect-acp client", (it) => {
       yield* Queue.offer(
         input,
         concatBytes(
-          yield* Effect.all(
-            ["permission-a", "permission-b"].map((id) =>
-              encodeJsonl(PermissionRequest, {
-                jsonrpc: "2.0",
-                id,
-                method: "session/request_permission",
-                params: payload,
-                headers: [],
-              }),
-            ),
+          yield* Effect.forEach(["permission-a", "permission-b"], (id) =>
+            encodeJsonl(PermissionRequest, {
+              jsonrpc: "2.0",
+              id,
+              method: "session/request_permission",
+              params: payload,
+              headers: [],
+            }),
           ),
         ),
       );
 
@@ -361,13 +361,14 @@ describe("AcpClientTerminals", () => {
           sessionId: "foreign-session",
           terminalId: created.terminalId,
         };
-        const results = yield* Effect.all(
+        const results = yield* Effect.forEach(
           [
             terminals.output(foreignRequest),
             terminals.waitForExit(foreignRequest),
             terminals.kill(foreignRequest),
             terminals.release(foreignRequest),
-          ].map((effect) => effect.pipe(Effect.result)),
+          ],
+          (effect) => effect.pipe(Effect.result),
           { concurrency: "unbounded" },
         );
 
 
@@ -24,6 +24,7 @@
         "namespaceImportPackages": ["@effect/platform-node", "effect"],
         "effectFn": ["span", "inferred-span", "suggested-span"],
         "diagnosticSeverity": {
+          "allOfMapToForEach": "error",
           "catchToOrElseSucceed": "error",
           "unnecessaryFailYieldableError": "error",
           "preferSucceedSomeOrNone": "error",