Optimized code.

Author: limingxinleo

src/Exception/InvalidRedisConnectionException.php

@@ -1,10 +1,19 @@
 <?php
 
+declare(strict_types=1);
+/**
+ * This file is part of Hyperf.
+ *
+ * @link     https://www.hyperf.io
+ * @document https://doc.hyperf.io
+ * @contact  [email protected]
+ * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ */
 
 namespace Hyperf\Redis\Exception;
 
+use RuntimeException;
 
-class InvalidRedisConnectionException
+class InvalidRedisConnectionException extends RuntimeException
 {
-
-}
+}

src/Redis.php

@@ -12,6 +12,7 @@
 
 namespace Hyperf\Redis;
 
+use Hyperf\Redis\Exception\InvalidRedisConnectionException;
 use Hyperf\Redis\Pool\PoolFactory;
 use Hyperf\Utils\Context;
 
@@ -89,7 +90,10 @@ private function getConnection($hasContextConnection): RedisConnection
         }
         if (! $connection instanceof RedisConnection) {
             $pool = $this->factory->getPool($this->poolName);
-            return $pool->get();
+            $connection = $pool->get();
+        }
+        if (! $connection instanceof RedisConnection) {
+            throw new InvalidRedisConnectionException('The connection is not a valid RedisConnection.');
         }
         return $connection;
     }