Added test cases for pipeline of redis. (#4997)

Author: limingxinleo

tests/RedisProxyTest.php

@@ -13,7 +13,9 @@
 
 use Hyperf\Config\Config;
 use Hyperf\Contract\ConfigInterface;
+use Hyperf\Contract\StdoutLoggerInterface;
 use Hyperf\Di\Container;
+use Hyperf\Engine\Channel as Chan;
 use Hyperf\Pool\Channel;
 use Hyperf\Pool\LowFrequencyInterface;
 use Hyperf\Pool\PoolOption;
@@ -117,13 +119,48 @@ public function testRedisHScan()
         $this->assertSame(0, $it);
     }
 
+    public function testRedisPipeline()
+    {
+        $redis = $this->getRedis();
+
+        $redis->rPush('pipeline:list', 'A');
+        $redis->rPush('pipeline:list', 'B');
+        $redis->rPush('pipeline:list', 'C');
+        $redis->rPush('pipeline:list', 'D');
+        $redis->rPush('pipeline:list', 'E');
+
+        $chan = new Chan(1);
+        $chan2 = new Chan(1);
+        go(static function () use ($redis, $chan) {
+            $redis->pipeline();
+            usleep(2000);
+            $redis->lRange('pipeline:list', 0, 1);
+            $redis->lTrim('pipeline:list', 2, -1);
+            usleep(1000);
+            $chan->push($redis->exec());
+        });
+
+        go(static function () use ($redis, $chan2) {
+            $redis->pipeline();
+            usleep(1000);
+            $redis->lRange('pipeline:list', 0, 1);
+            $redis->lTrim('pipeline:list', 2, -1);
+            usleep(10000);
+            $chan2->push($redis->exec());
+        });
+
+        $this->assertSame([['A', 'B'], true], $chan->pop());
+        $this->assertSame([['C', 'D'], true], $chan2->pop());
+    }
+
     /**
      * @param mixed $optinos
      * @return \Redis
      */
     private function getRedis($optinos = [])
     {
         $container = Mockery::mock(Container::class);
+        $container->shouldReceive('has')->with(StdoutLoggerInterface::class)->andReturnFalse();
         $container->shouldReceive('get')->once()->with(ConfigInterface::class)->andReturn(new Config([
             'redis' => [
                 'default' => [

tests/RedisTest.php

@@ -70,9 +70,11 @@ public function testRedisSelect()
 
         $this->assertSame(2, $redis->getDatabase());
 
-        $res = parallel([function () use ($redis) {
-            return $redis->get('xxxx');
-        }]);
+        $res = parallel([
+            function () use ($redis) {
+                return $redis->get('xxxx');
+            },
+        ]);
 
         $this->assertSame('db:0 name:get argument:xxxx', $res[0]);
     }