diff --git a/src/Pole.Domain.EntityframeworkCore/MediatR/MediatorExtension.cs b/src/Pole.Domain.EntityframeworkCore/MediatR/MediatorExtension.cs index f91d849..e6a32b2 100644 --- a/src/Pole.Domain.EntityframeworkCore/MediatR/MediatorExtension.cs +++ b/src/Pole.Domain.EntityframeworkCore/MediatR/MediatorExtension.cs @@ -24,10 +24,13 @@ namespace Pole.EntityframeworkCore.MediatR domainEntities.ToList() .ForEach(entity => entity.Entity.ClearDomainEvents()); - foreach(var domainEvent in domainEvents) - { - await mediator.Publish(domainEvent); - } + var tasks = domainEvents + .Select(async (domainEvent) => + { + await mediator.Publish(domainEvent); + }); + + await Task.WhenAll(tasks); } } }