Code Duplication    Length = 9-9 lines in 2 locations

src/Redis/RedisReceive.php 1 location

@@ 69-77 (lines=9) @@
66
     *
67
     * @throws MessageReceiveException
68
     */
69
    public function receiveAll(): array
70
    {
71
        $messages = [];
72
        while (null !== $message = $this->receive()) {
73
            $messages[] = $message;
74
        }
75
76
        return $messages;
77
    }
78
}
79

src/AbstractMessageReceive.php 1 location

@@ 12-20 (lines=9) @@
9
     *
10
     * @throws MessageReceiveException
11
     */
12
    public function receiveAll(): array
13
    {
14
        $messages = [];
15
        while (null !== $message = $this->receive()) {
16
            $messages[] = $message;
17
        }
18
19
        return $messages;
20
    }
21
}
22