Concurrent execution of event handlers in dispatcher

kamu-data · Nov 23, 2023 · bbe8ed0 · bbe8ed0
1 parent 7611215
commit bbe8ed0
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/src/utils/event-bus/Cargo.toml b/src/utils/event-bus/Cargo.toml
@@ -20,5 +20,6 @@ doctest = false
 [dependencies]
 internal-error = { workspace = true }
 dill = "0.7"
+futures = "0.3"
 
 [dev-dependencies]
diff --git a/src/utils/event-bus/src/event_bus.rs b/src/utils/event-bus/src/event_bus.rs
@@ -47,12 +47,12 @@ impl EventBus {
             }
         };
 
-        // TODO: concurrent launch
-        for handler in handlers.iter() {
-            (*handler)
-                .call((self.catalog.clone(), event.clone()))
-                .await?;
-        }
+        let handler_futures: Vec<_> = handlers
+            .iter()
+            .map(|handler| (*handler).call((self.catalog.clone(), event.clone())))
+            .collect();
+
+        futures::future::try_join_all(handler_futures).await?;
 
         Ok(())
     }