e

2020-09-11 14:51:15 +08:00
parent d62b2b8228
commit 4c144b24c7
1 changed files with 3 additions and 1 deletions
@@ -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());