|
@@ -39,6 +39,10 @@ discard block |
|
|
block discarded – undo |
|
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 |
|
|
block discarded – undo |
|
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( |
Please login to merge, or discard this patch.