Fix support for CatchUpOptions::maximumSequenceNumber

neos · Aug 11, 2023 · 64322c8 · 64322c8
1 parent 19af2f6
commit 64322c8
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/Neos.ContentRepository.Core/Classes/ContentRepository.php b/Neos.ContentRepository.Core/Classes/ContentRepository.php
@@ -166,6 +166,9 @@ public function catchUpProjection(string $projectionClassName, CatchUpOptions $o
         // TODO allow custom stream name per projection
         $streamName = VirtualStreamName::all();
         $eventStream = $this->eventStore->load($streamName);
+        if ($options->maximumSequenceNumber !== null) {
+            $eventStream = $eventStream->withMaximumSequenceNumber($options->maximumSequenceNumber);
+        }
 
         $eventApplier = function (EventEnvelope $eventEnvelope) use ($projection, $catchUpHook) {
             $event = $this->eventNormalizer->denormalize($eventEnvelope->event);