From 6638cc21684f2b63ce5ba5f27da02679f8e6a750 Mon Sep 17 00:00:00 2001
From: David Badura <david.badura@patchlevel.de>
Date: Wed, 6 Mar 2024 09:57:59 +0100
Subject: [PATCH] fix watch command

---
 src/Console/Command/WatchCommand.php | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/Console/Command/WatchCommand.php b/src/Console/Command/WatchCommand.php
index 3f323af5e..142b6cb04 100644
--- 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();
             },
             [],