There was an error while loading. Please reload this page.
2 parents f94b69f + c89542d commit ebc5859Copy full SHA for ebc5859
src/Server/Manager.php
@@ -260,11 +260,19 @@ protected function resetOnRequest()
260
*
261
* @param mixed $server
262
* @param string|\Swoole\Server\Task $taskId or $task
263
- * @param string $srcWorkerId
264
- * @param mixed $data
+ * @param string|null $srcWorkerId
+ * @param mixed|null $data
265
*/
266
- public function onTask($server, $taskId, $srcWorkerId, $data)
+ public function onTask($server, $task, $srcWorkerId = null, $data = null)
267
{
268
+ if ($task instanceof Task) {
269
+ $data = $task->data;
270
+ $srcWorkerId = $task->worker_id;
271
+ $taskId = $task->id;
272
+ } else {
273
+ $taskId = $task;
274
+ }
275
+
276
$this->container->make('events')->dispatch('swoole.task', func_get_args());
277
278
try {
0 commit comments