Skip to content

Commit 62f652a

Browse files
authored
Handle empty message queue in CachePoolStore::pop()
1 parent b1e54f1 commit 62f652a

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/Server/Transport/Sse/Store/CachePoolStore.php

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,11 @@ public function pop(Uuid $id): ?string
4545
}
4646

4747
$messages = $item->get();
48+
49+
if ([] === $messages) {
50+
return null;
51+
}
52+
4853
$message = array_shift($messages);
4954

5055
$item->set($messages);

0 commit comments

Comments
 (0)