mindol1004/cqrs-eventsourcing-user-management-example
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Refactor. | #GrammarNazi (C) whatthecommit.com

Browse Source
This commit is contained in:
Maksim Kostromin
2019-08-01 03:27:07 +03:00
parent 674f88a4d5
commit bb04e27b73
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/groovy/com/github/daggerok/eventsourcing/aggregate/repository/InMemoryUserRepository.java
View File

@@ -20,8 +20,9 @@ public class InMemoryUserRepository implements UserRepository {
UUID aggregateId = user.getUserId();
Collection<DomainEvent> newEvents = user.getEventStream();
Collection<DomainEvent> oldEvents = eventStore.getOrDefault(aggregateId, new CopyOnWriteArrayList<>());
eventStore.put(aggregateId, Stream.concat(oldEvents.stream(), newEvents.stream())
.collect(Collectors.toList()));
Collection<DomainEvent> events = Stream.concat(oldEvents.stream(), newEvents.stream())
.collect(Collectors.toList());
eventStore.put(aggregateId, new CopyOnWriteArrayList<>(events));
user.flushEvents();
}