Wait for all proc to complete before throwing

kepler16 · Dec 3, 2024 · 5fbf3dd · 5fbf3dd
1 parent 99a7542
commit 5fbf3dd
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/packages/kmono-build/src/k16/kmono/build.clj b/packages/kmono-build/src/k16/kmono/build.clj
@@ -160,5 +160,17 @@
                         (.release semaphore)))))
                 stage)]
 
-           (mapv deref op-procs)
+           ;; First deref everything, handling exceptions. This ensures that all
+           ;; procs finish before any exceptions are thrown.
+           ;;
+           ;; Once all procs are complete then throw if any were exceptional.
+           (->> op-procs
+                (mapv (fn [proc]
+                        (try
+                          (deref proc)
+                          (catch Exception ex ex))))
+                (run! (fn [val]
+                        (when (instance? Exception val)
+                          (throw val)))))
+
            (recur (rest stages))))))))