fix merge conflict

patchlevel · Dec 8, 2024 · 4a76066 · 4a76066
1 parent 96b8640
commit 4a76066
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/src/Subscription/Engine/DefaultSubscriptionEngine.php b/src/Subscription/Engine/DefaultSubscriptionEngine.php
@@ -199,7 +199,7 @@ function (SubscriptionCollection $subscriptions) use ($limit): ProcessedResult {
                     $messageCounter = 0;
 
                     try {
-                        $stream = $this->messageLoader->load($startIndex, $subscriptions);
+                        $stream = $this->messageLoader->load($startIndex, $subscriptions->toArray());
 
                         foreach ($stream as $message) {
                             $messageCounter++;
@@ -370,7 +370,7 @@ function (SubscriptionCollection $subscriptions) use ($limit): ProcessedResult {
                     $messageCounter = 0;
 
                     try {
-                        $stream = $this->messageLoader->load($startIndex, $subscriptions);
+                        $stream = $this->messageLoader->load($startIndex, $subscriptions->toArray());
 
                         foreach ($stream as $message) {
                             $messageCounter++;

diff --git a/src/Subscription/Engine/SubscriptionCollection.php b/src/Subscription/Engine/SubscriptionCollection.php
@@ -64,4 +64,10 @@ public function lowestPosition(): int
 
         return $min;
     }
+
+    /** @return list<Subscription> */
+    public function toArray(): array
+    {
+        return $this->subscriptions;
+    }
 }