|
@ -21,12 +21,8 @@ namespace Ordering.Infrastructure |
|
|
domainEntities.ToList() |
|
|
domainEntities.ToList() |
|
|
.ForEach(entity => entity.Entity.ClearDomainEvents()); |
|
|
.ForEach(entity => entity.Entity.ClearDomainEvents()); |
|
|
|
|
|
|
|
|
var tasks = domainEvents |
|
|
|
|
|
.Select(async (domainEvent) => { |
|
|
|
|
|
await mediator.Publish(domainEvent); |
|
|
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
await Task.WhenAll(tasks); |
|
|
|
|
|
|
|
|
foreach (var domainEvent in domainEvents) |
|
|
|
|
|
await mediator.Publish(domainEvent); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |