@@ -39,6 +39,10 @@ discard block |
||
| 39 | 39 | $this->appendEventsForAggregateWithoutChecking($aggregateId, $aggregateClass, $eventsWithMetaData, $expectedVersion, $expectedSequence); |
| 40 | 40 | } |
| 41 | 41 | |
| 42 | + /** |
|
| 43 | + * @param string $aggregateClass |
|
| 44 | + * @param EventWithMetaData[] $newEvents |
|
| 45 | + */ |
|
| 42 | 46 | public function appendEventsForAggregateWithoutChecking($aggregateId, $aggregateClass, $newEvents, int $expectedVersion, int $expectedSequence) |
| 43 | 47 | { |
| 44 | 48 | $this->addEventsToArrayForAggregate( |
@@ -68,6 +72,9 @@ discard block |
||
| 68 | 72 | : []; |
| 69 | 73 | } |
| 70 | 74 | |
| 75 | + /** |
|
| 76 | + * @param EventWithMetaData[] $newEvents |
|
| 77 | + */ |
|
| 71 | 78 | private function addEventsToArrayForAggregate($aggregateId, $aggregateClass, $newEvents, int $expectedVersion, int $expectedSequence) |
| 72 | 79 | { |
| 73 | 80 | $this->commitsByAggregate[$this->constructKey($aggregateClass, $aggregateId)][] = new EventsCommit( |
@@ -12,7 +12,6 @@ |
||
| 12 | 12 | use Gica\Cqrs\EventStore\EventStreamGroupedByCommit; |
| 13 | 13 | use Gica\Cqrs\EventStore\Exception\ConcurrentModificationException; |
| 14 | 14 | use Gica\Iterator\IteratorTransformer\IteratorExpander; |
| 15 | -use Gica\Types\Guid; |
|
| 16 | 15 | |
| 17 | 16 | class InMemoryEventStore implements EventStore |
| 18 | 17 | { |