diff --git a/src/utils/event-bus/src/event_bus.rs b/src/utils/event-bus/src/event_bus.rs index adf77ff36b..ea480746d4 100644 --- a/src/utils/event-bus/src/event_bus.rs +++ b/src/utils/event-bus/src/event_bus.rs @@ -93,7 +93,8 @@ impl EventBus { .map(|handler| handler.handle(event)) .collect(); - futures::future::try_join_all(async_handler_futures).await?; + let results = futures::future::join_all(async_handler_futures).await; + results.into_iter().try_for_each(|res| res)?; Ok(()) } @@ -116,7 +117,8 @@ impl EventBus { .map(|handler| (*handler).call((event_arc.clone(),))) .collect(); - futures::future::try_join_all(closure_handler_futures).await?; + let results = futures::future::join_all(closure_handler_futures).await; + results.into_iter().try_for_each(|res| res)?; } Ok(())