diff --git a/src/Umbraco.Core/Events/EventAggregator.Notifications.cs b/src/Umbraco.Core/Events/EventAggregator.Notifications.cs index d65c8f772c..5676af3f3c 100644 --- a/src/Umbraco.Core/Events/EventAggregator.Notifications.cs +++ b/src/Umbraco.Core/Events/EventAggregator.Notifications.cs @@ -238,7 +238,7 @@ internal class NotificationAsyncHandlerWrapperImpl : Notifica /// confusion. /// /// - public override Task HandleAsync( + public override async Task HandleAsync( IEnumerable notifications, CancellationToken cancellationToken, ServiceFactory serviceFactory, @@ -256,7 +256,7 @@ internal class NotificationAsyncHandlerWrapperImpl : Notifica .Select(x => new Func, CancellationToken, Task>( (handlerNotifications, handlerCancellationToken) => x.HandleAsync(handlerNotifications.Cast(), handlerCancellationToken))); - return publish(handlers, notifications, cancellationToken); + await publish(handlers, notifications, cancellationToken); } } diff --git a/src/Umbraco.Core/Events/EventAggregator.cs b/src/Umbraco.Core/Events/EventAggregator.cs index caaa160146..9861b1a318 100644 --- a/src/Umbraco.Core/Events/EventAggregator.cs +++ b/src/Umbraco.Core/Events/EventAggregator.cs @@ -42,13 +42,13 @@ public partial class EventAggregator : IEventAggregator } /// - public Task PublishAsync(IEnumerable notifications, CancellationToken cancellationToken = default) + public async Task PublishAsync(IEnumerable notifications, CancellationToken cancellationToken = default) where TNotification : INotification where TNotificationHandler : INotificationHandler { PublishNotifications(notifications); - return PublishNotificationsAsync(notifications, cancellationToken); + await PublishNotificationsAsync(notifications, cancellationToken); } ///