Merge pull request #558 from patchlevel/fix-log-output

fix log output end of stream in subscription engine
patchlevel · Mar 27, 2024 · 1fd21cb · 1fd21cb
2 parents b774028 + a54b413
commit 1fd21cb
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,
                     ),
                 );
             },