@@ -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 | { |
@@ -46,6 +46,9 @@ |
||
46 | 46 | $this->log($outputFilePath, $files); |
47 | 47 | } |
48 | 48 | |
49 | + /** |
|
50 | + * @param string $outputFilePath |
|
51 | + */ |
|
49 | 52 | abstract protected function log($outputFilePath); |
50 | 53 | |
51 | 54 | abstract protected function discover(string $searchDirectory): array; |