From 4c144b24c7f9dbcc3567db812b9fc72f9390cc15 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Fri, 11 Sep 2020 14:51:15 +0800 Subject: [PATCH] e --- Queue/Queue.php | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/Queue/Queue.php b/Queue/Queue.php index e3a91e95..f54bbd4b 100644 --- a/Queue/Queue.php +++ b/Queue/Queue.php @@ -66,7 +66,9 @@ class Queue extends \Snowflake\Process\Process if (empty($data)) { Coroutine::sleep(0.05); } else { - Coroutine::create([$this, 'scheduler'], $data); + Coroutine::create(function ($params) { + $this->scheduler($params); + }, $data); } } catch (\Throwable $exception) { $this->application->error($exception->getMessage());