Conditions | 5 |
Paths | 6 |
Total Lines | 13 |
Code Lines | 7 |
Lines | 0 |
Ratio | 0 % |
Tests | 8 |
CRAP Score | 5 |
Changes | 1 | ||
Bugs | 0 | Features | 0 |
1 | <?php |
||
59 | 1 | public function retrieveAllAfterVersion(AggregateRootId $id, int $aggregateRootVersion): Generator |
|
60 | { |
||
61 | 1 | $lastMessage = null; |
|
62 | |||
63 | 1 | foreach ($this->messages as $message) { |
|
64 | 1 | if ($id->toString() === $message->header(Header::AGGREGATE_ROOT_ID)->toString() |
|
65 | 1 | && $message->header(Header::AGGREGATE_ROOT_VERSION) > $aggregateRootVersion) { |
|
66 | 1 | yield $message; |
|
67 | 1 | $lastMessage = $message; |
|
68 | } |
||
69 | } |
||
70 | |||
71 | 1 | return $lastMessage instanceof Message ? $lastMessage->aggregateVersion() : 0; |
|
72 | } |
||
74 |