feature:inject AsyncTaskSynchronizer to taskMethod

normal-ai · normal-ai · commit ff4ff354b653 · 2022-12-17T10:03:34.000+08:00
diff --git a/src/command/AsyncTaskService.php b/src/command/AsyncTaskService.php
@@ -93,7 +93,7 @@ public function start(string $host, int $port, array $option = []){
             $taskSynchronizer = new AsyncTaskSynchronizer($taskKey, $option['synchronizer_ttl']);
             try{
                 $class = is_object($taskClass) ?: app($taskClass);
-                $class->$taskMethod($taskData);
+                $class->$taskMethod($taskData, $taskSynchronizer);
             }catch (Exception $e){
                 $taskSynchronizer->error($e->getMessage());
             }

Original file line number	Diff line number	Diff line change
`@@ -93,7 +93,7 @@ public function start(string $host, int $port, array $option = []){`
`93`	`93`	`$taskSynchronizer = new AsyncTaskSynchronizer($taskKey, $option['synchronizer_ttl']);`
`94`	`94`	`try{`
`95`	`95`	`$class = is_object($taskClass) ?: app($taskClass);`
`96`		`- $class->$taskMethod($taskData);`
	`96`	`+ $class->$taskMethod($taskData, $taskSynchronizer);`
`97`	`97`	`}catch (Exception $e){`
`98`	`98`	`$taskSynchronizer->error($e->getMessage());`
`99`	`99`	`}`