improve batch processing in projectionist

patchlevel · Mar 3, 2024 · 7b543d6 · 7b543d6
1 parent f898567
commit 7b543d6
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/src/Projection/Projectionist/DefaultProjectionist.php b/src/Projection/Projectionist/DefaultProjectionist.php
@@ -141,6 +141,10 @@ function ($projections) use ($limit): void {
                         }
                     }
                 } finally {
+                    foreach ($projections as $projection) {
+                        $this->projectionStore->update($projection);
+                    }
+
                     $stream?->close();
                 }
 
@@ -263,6 +267,10 @@ function (array $projections) use ($limit): void {
                         }
                     }
                 } finally {
+                    foreach ($projections as $projection) {
+                        $this->projectionStore->update($projection);
+                    }
+
                     $stream?->close();
                 }
 
@@ -547,7 +555,6 @@ private function handleMessage(int $index, Message $message, Projection $project
 
         if ($subscribeMethods === []) {
             $projection->changePosition($index);
-            $this->projectionStore->update($projection);
 
             $this->logger?->debug(
                 sprintf(
@@ -583,7 +590,6 @@ private function handleMessage(int $index, Message $message, Projection $project
 
         $projection->changePosition($index);
         $projection->resetRetry();
-        $this->projectionStore->update($projection);
 
         $this->logger?->debug(
             sprintf(