From 4a7606609fb9c29aebc410654a2164e7b40e7703 Mon Sep 17 00:00:00 2001
From: David Badura <david.badura@patchlevel.de>
Date: Sun, 8 Dec 2024 13:04:05 +0100
Subject: [PATCH] fix merge conflict

---
 src/Subscription/Engine/DefaultSubscriptionEngine.php | 4 ++--
 src/Subscription/Engine/SubscriptionCollection.php    | 6 ++++++
 2 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/src/Subscription/Engine/DefaultSubscriptionEngine.php b/src/Subscription/Engine/DefaultSubscriptionEngine.php
index d419d7a44..6fafeb818 100644
--- 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
index f1ed60b55..a8fba233c 100644
--- 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;
+    }
 }