fix watch command

patchlevel · Mar 6, 2024 · 6638cc2 · 6638cc2
1 parent afc4913
commit 6638cc2
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/Console/Command/WatchCommand.php b/src/Console/Command/WatchCommand.php
@@ -75,10 +75,9 @@ function () use ($console, &$index, $aggregate, $aggregateId): void {
 
                 foreach ($stream as $message) {
                     $console->message($this->serializer, $message);
+                    $index = $stream->index();
                 }
 
-                $index = $stream->index();
-
                 $stream->close();
             },
             [],