hotfix

Author: bazilio91

tests/unit/BaseTestClass.php

@@ -211,26 +211,11 @@ public function testSubscribe()
             return;
         }
 
-        $manager = new \Spork\ProcessManager();
-
         $task = new TestTask();
         $task->id = 1;
 
-
-        $fork = $manager->fork(
-            function () use ($task) {
-                return \Yii::$app->asyncFork->waitAndReceive($task::$queueName);
-            }
-        );
-
         \Yii::$app->async->sendTask($task);
 
-        $fork->then(
-            function (\Spork\Fork $fork) {
-                $task = $fork->getResult();
-                $this->assertNotEmpty($task);
-                $this->assertEquals(1, $task->execute());
-            }
-        );
+        $this->assertNotFalse(\Yii::$app->async->receiveTask($task::$queueName, true));
     }
 }

transports/AsyncRedisTransport.php

@@ -50,9 +50,13 @@ public function send($text, $queueName)
      */
     public function receive($queueName, $wait = false)
     {
+        $params = [self::getQueueKey($queueName), self::getQueueKey($queueName, true)];
+        if ($wait) {
+            $params[] = 0;
+        }
         $message = $this->connection->executeCommand(
             ($wait ? 'BRPOPLPUSH' : 'RPOPLPUSH'),
-            [self::getQueueKey($queueName), self::getQueueKey($queueName, true)]
+            $params
         );
 
         if (!$message) {