Refactor message retrieval in CachePoolAdapter.

Updated `receiveMessages` to fetch messages in a loop using `popMessage`. Adjusted corresponding test case to validate the new behavior with consecutive calls and added stricter assertions for cache interactions.

Author: klapaudius

src/Transports/SseAdapters/CachePoolAdapter.php

@@ -77,7 +77,12 @@ public function removeAllMessages(string $clientId): void
      */
     public function receiveMessages(string $clientId): array
     {
-        return $this->cache->getItem($this->generateQueueKey($clientId))->get() ?? [];
+        $messages = [];
+        while ($message = $this->popMessage($clientId)) {
+            $messages[] = $message;
+        }
+
+        return $messages;
     }
 
     /**

tests/Transports/SseAdapters/CachePoolAdapterTest.php

@@ -192,8 +192,29 @@ public function test_receive_messages_returns_array_of_messages(): void
             ->willReturn($this->cacheItemMock);
 
         $this->cacheItemMock
+            ->expects($this->exactly(3))
             ->method('get')
-            ->willReturn($messages);
+            ->willReturnOnConsecutiveCalls(
+                ['Message 1', 'Message 2'],
+                ['Message 2'],
+                []
+            );
+        $invocations = [
+            ['Message 2'],
+            [],
+            []
+        ];
+        $this->cacheItemMock
+            ->expects($matcher = $this->exactly(count($invocations)))
+            ->method('set')
+            ->with($this->callback(function ($value) use ($invocations, $matcher) {
+                $this->assertEquals($value, $invocations[$matcher->numberOfInvocations()-1]);
+                return true;
+            }));
+        $this->cacheMock
+            ->expects($this->exactly(count($invocations)))
+            ->method('save')
+            ->with($this->cacheItemMock);
 
         $result = $this->adapter->receiveMessages($clientId);