Concurrent execution of event handlers in dispatcher

Author: zaychenko-sergei

Cargo.lock

@@ -20,5 +20,6 @@ doctest = false
 [dependencies]
 internal-error = { workspace = true }
 dill = "0.7"
+futures = "0.3"
 
 [dev-dependencies]

src/utils/event-bus/Cargo.toml

@@ -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(())
     }