SwooleTW\Http\Task\SwooleTask

Complexity

Total Complexity

3

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	async()	0	5	2

<?php

namespace SwooleTW\Http\Task;

use Closure;
use SuperClosure\Serializer;

class SwooleTask
{
    /**
     * The swoole http server instace.
     *
     * @var \Swoole\Http\Server
     */
    protected $server;

    /**
     * Task constructor
     */
    public function __construct($server)
    {
        $this->server = $server->getServer();
    }

    /**
     * Swoole Async task
     *
     * @param object  $task
     * @param mixed  $callback
     * @param int  $taskWorkerId
     *
     * @return mixed
     */
    public function async(callable $task, callable $callback = null, $taskWorkerId = 1)
    {
        $serializedTask = $task instanceof Closure ? (new Serializer)->serialize($task) : serialize($task);

        return $this->server->task($serializedTask, $taskWorkerId, $callback);
    }
}