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/SystemV/SystemVReceive.php 1 location

@@ 95-103 (lines=9) @@
92
     *
93
     * @throws MessageReceiveException
94
     */
95
    public function receiveAll(): array
96
    {
97
        $messages = [];
98
        while (null !== $message = $this->receive()) {
99
            $messages[] = $message;
100
        }
101
102
        return $messages;
103
    }
104
}
105