Passed
Pull Request — master (#132)
by
unknown
02:31
created

SwooleTask::__construct()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 3
Code Lines 1

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
cc 1
eloc 1
c 0
b 0
f 0
nc 1
nop 1
dl 0
loc 3
rs 10
1
<?php
2
3
namespace SwooleTW\Http\Task;
4
5
use Closure;
6
use SuperClosure\Serializer;
7
8
class SwooleTask
9
{
10
    /**
11
     * The swoole http server instace.
12
     *
13
     * @var \Swoole\Http\Server
14
     */
15
    protected $server;
16
17
    /**
18
     * Task constructor
19
     */
20
    public function __construct($server)
21
    {
22
        $this->server = $server->getServer();
23
    }
24
25
    /**
26
     * Swoole Async task
27
     *
28
     * @param object  $task
29
     * @param mixed  $callback
30
     * @param int  $taskWorkerId
31
     *
32
     * @return mixed
33
     */
34
    public function async(callable $task, callable $callback = null, $taskWorkerId = 1)
35
    {
36
        $serializedTask = $task instanceof Closure ? (new Serializer)->serialize($task) : serialize($task);
37
38
        return $this->server->task($serializedTask, $taskWorkerId, $callback);
39
    }
40
}
41