almost all

tests/mutex/MutexConcurrencyTest.php

@@ -60,7 +60,7 @@ private function getPDO(string $dsn, string $user, string $password): \PDO
      * @param int      $concurrency the amount of forks
      * @param callable $code        the code for the fork
      */
-    private function fork(int $concurrency, callable $code)
+    private function fork(int $concurrency, callable $code): void
     {
         $pool = Pool::create();
 

tests/mutex/PHPRedisMutexTest.php

@@ -90,6 +90,9 @@ public function close(): bool
                     return $res;
                 }
 
+                /**
+                 * @return \Redis|string|bool
+                 */
                 private function _set($key, $value, $timeout = 0)
                 {
                     if ($this->is_closed) {
@@ -99,6 +102,9 @@ private function _set($key, $value, $timeout = 0)
                     return parent::set($key, $value, $timeout);
                 }
 
+                /**
+                 * @return mixed
+                 */
                 private function _eval($script, $args = [], $numKeys = 0)
                 {
                     if ($this->is_closed) {
@@ -126,7 +132,7 @@ private function _eval($script, $args = [], $numKeys = 0)
         $this->mutex = new PHPRedisMutex($this->connections, 'test');
     }
 
-    private function closeMajorityConnections()
+    private function closeMajorityConnections(): void
     {
         $numberToClose = (int) ceil(count($this->connections) / 2);
 
@@ -135,7 +141,7 @@ private function closeMajorityConnections()
         }
     }
 
-    private function closeMinorityConnections()
+    private function closeMinorityConnections(): void
     {
         if (count($this->connections) === 1) {
             self::markTestSkipped('Cannot test this with only a single Redis server');
@@ -176,6 +182,9 @@ public function testEvalScriptFails(): void
     }
 
     /**
+     * @param \Redis::SERIALIZER_*  $serializer
+     * @param \Redis::COMPRESSION_* $compressor
+     *
      * @dataProvider provideSerializersAndCompressorsCases
      */
     public function testSerializersAndCompressors($serializer, $compressor): void