Commit 06f7c1ca by dingsongjie

DispatchDomainEventsAsync 优化

parent 2d8ef67d
...@@ -24,10 +24,13 @@ namespace Pole.EntityframeworkCore.MediatR ...@@ -24,10 +24,13 @@ namespace Pole.EntityframeworkCore.MediatR
domainEntities.ToList() domainEntities.ToList()
.ForEach(entity => entity.Entity.ClearDomainEvents()); .ForEach(entity => entity.Entity.ClearDomainEvents());
foreach(var domainEvent in domainEvents) var tasks = domainEvents
{ .Select(async (domainEvent) =>
await mediator.Publish(domainEvent); {
} await mediator.Publish(domainEvent);
});
await Task.WhenAll(tasks);
} }
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment