Passed
Pull Request — master (#31)
by Shinji
04:07 queued 02:36
created

receiveTraceOrDetachWorker()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 4
Code Lines 1

Duplication

Lines 0
Ratio 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
cc 1
eloc 1
c 1
b 0
f 0
nc 1
nop 0
dl 0
loc 4
rs 10
1
<?php
2
3
/**
4
 * This file is part of the sj-i/php-profiler package.
5
 *
6
 * (c) sji <[email protected]>
7
 *
8
 * For the full copyright and license information, please view the LICENSE
9
 * file that was distributed with this source code.
10
 */
11
12
declare(strict_types=1);
13
14
namespace PhpProfiler\Inspector\Daemon\Reader\Controller;
15
16
use Amp\Parallel\Sync\Channel;
0 ignored issues
show
Bug introduced by
The type Amp\Parallel\Sync\Channel was not found. Maybe you did not declare it correctly or list all dependencies?

The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. excluded_paths: ["lib/*"], you can move it to the dependency path list as follows:

filter:
    dependency_paths: ["lib/*"]

For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths

Loading history...
17
use Amp\Promise;
0 ignored issues
show
Bug introduced by
The type Amp\Promise was not found. Maybe you did not declare it correctly or list all dependencies?

The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. excluded_paths: ["lib/*"], you can move it to the dependency path list as follows:

filter:
    dependency_paths: ["lib/*"]

For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths

Loading history...
18
use PhpProfiler\Inspector\Daemon\Reader\Protocol\Message\AttachMessage;
19
use PhpProfiler\Inspector\Daemon\Reader\Protocol\Message\DetachWorkerMessage;
20
use PhpProfiler\Inspector\Daemon\Reader\Protocol\Message\SetSettingsMessage;
21
use PhpProfiler\Inspector\Daemon\Reader\Protocol\Message\TraceMessage;
22
use PhpProfiler\Inspector\Daemon\Reader\Protocol\PhpReaderControllerProtocolInterface;
23
24
final class PhpReaderControllerProtocol implements PhpReaderControllerProtocolInterface
25
{
26
    private Channel $channel;
27
28
    public function __construct(Channel $channel)
29
    {
30
        $this->channel = $channel;
31
    }
32
33
    public static function createFromChannel(Channel $channel): self
34
    {
35
        return new self($channel);
36
    }
37
38
    public function sendSettings(SetSettingsMessage $message): Promise
39
    {
40
        return $this->channel->send($message);
41
    }
42
43
    public function sendAttach(AttachMessage $message): Promise
44
    {
45
        return $this->channel->send($message);
46
    }
47
48
    /**
49
     * @return Promise<TraceMessage|DetachWorkerMessage>
50
     */
51
    public function receiveTraceOrDetachWorker(): Promise
52
    {
53
        /** @var Promise<TraceMessage|DetachWorkerMessage> */
54
        return $this->channel->receive();
55
    }
56
}
57