@@ -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( |