fix log output end of stream in subscription engine

patchlevel · Mar 27, 2024 · a54b413 · a54b413
1 parent 8b0a476
commit a54b413
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Subscription/Engine/DefaultSubscriptionEngine.php b/src/Subscription/Engine/DefaultSubscriptionEngine.php
@@ -347,7 +347,7 @@ function (array $subscriptions) use ($limit): void {
                         }
                     }
                 } finally {
-                    $endIndex = $stream?->index();
+                    $endIndex = $stream?->index() ?: $startIndex;
                     $stream?->close();
 
                     if ($messageCounter > 0) {
@@ -382,7 +382,7 @@ function (array $subscriptions) use ($limit): void {
                 $this->logger?->info(
                     sprintf(
                         'Subscription Engine: End of stream on position "%d" has been reached, finish processing.',
-                        $endIndex ?: 'unknown',
+                        $endIndex,
                     ),
                 );
             },