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

Refactor. | Merging 'WIP: Do Not Merge This Branch' Into Master (C) whatthecommit.com

Browse Source
This commit is contained in:
Maksim Kostromin
2019-08-01 03:23:00 +03:00
parent 0297e4498d
commit 674f88a4d5
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -3,11 +3,11 @@ package com.github.daggerok.eventsourcing.aggregate.repository;
import com.github.daggerok.eventsourcing.aggregate.User;
import com.github.daggerok.eventsourcing.aggregate.event.DomainEvent;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Map;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@@ -17,10 +17,11 @@ public class InMemoryUserRepository implements UserRepository {
@Override
public void save(User user) {
Collection<DomainEvent> domainEvents = eventStore.getOrDefault(user.getUserId(), new ArrayList<>());
Collection<DomainEvent> newEvents = Stream.concat(domainEvents.stream(), user.getEventStream().stream())
.collect(Collectors.toList());
eventStore.put(user.getUserId(), newEvents);
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()));
user.flushEvents();
}