Browse Source

Improved encapsulation of DomainEvents collection in Entity class

pull/561/head
Alex Kryvdyk 6 years ago
parent
commit
1d8c6178de
2 changed files with 10 additions and 5 deletions
  1. +9
    -4
      src/Services/Ordering/Ordering.Domain/SeedWork/Entity.cs
  2. +1
    -1
      src/Services/Ordering/Ordering.Infrastructure/MediatorExtension.cs

+ 9
- 4
src/Services/Ordering/Ordering.Domain/SeedWork/Entity.cs View File

@ -21,17 +21,22 @@
} }
private List<INotification> _domainEvents; private List<INotification> _domainEvents;
public List<INotification> DomainEvents => _domainEvents;
public IReadOnlyCollection<INotification> DomainEvents => _domainEvents?.AsReadOnly();
public void AddDomainEvent(INotification eventItem) public void AddDomainEvent(INotification eventItem)
{ {
_domainEvents = _domainEvents ?? new List<INotification>(); _domainEvents = _domainEvents ?? new List<INotification>();
_domainEvents.Add(eventItem); _domainEvents.Add(eventItem);
} }
public void RemoveDomainEvent(INotification eventItem) public void RemoveDomainEvent(INotification eventItem)
{ {
if (_domainEvents is null) return;
_domainEvents.Remove(eventItem);
_domainEvents?.Remove(eventItem);
}
public void ClearDomainEvents()
{
_domainEvents?.Clear();
} }
public bool IsTransient() public bool IsTransient()


+ 1
- 1
src/Services/Ordering/Ordering.Infrastructure/MediatorExtension.cs View File

@ -19,7 +19,7 @@ namespace Ordering.Infrastructure
.ToList(); .ToList();
domainEntities.ToList() domainEntities.ToList()
.ForEach(entity => entity.Entity.DomainEvents.Clear());
.ForEach(entity => entity.Entity.ClearDomainEvents());
var tasks = domainEvents var tasks = domainEvents
.Select(async (domainEvent) => { .Select(async (domainEvent) => {


Loading…
Cancel
Save