Task::timeout() - Code Metrics - Inspection of "Double resolve problem fixed" - phpinnacle/ensign - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( ca9c7f...904700 )

by PHPinnacle

created 2018-07-23 14:25 UTC

Task::timeout() A

↳ Parent: Task

Complexity

Conditions	3
Paths	1

Size

Total Lines	31
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	18
CRAP Score	3.0013

Importance

Changes

Metric	Value
cc	3
eloc	16
nc	1
nop	1
dl	0
loc	31
ccs	18
cts	19
cp	0.9474
crap	3.0013
rs	9.7333
c	0
b	0
f	0

<?php
/**
 * This file is part of PHPinnacle/Ensign.
 *
 * (c) PHPinnacle Team <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types = 1);

namespace PHPinnacle\Ensign;

use Amp\Deferred;
use Amp\Loop;
use Amp\Promise;

final class Task implements Promise
{
    /**
     * @var int
     */
    private $id;

    /**
     * @var Promise
     */
    private $promise;

    /**
     * @var Token
     */
    private $token;

    /**
     * @param int     $id
     * @param Promise $promise
     * @param Token   $token
     */
    public function __construct(int $id, Promise $promise, Token $token)
    {
        $this->id      = $id;
        $this->promise = $promise;
        $this->token   = $token;
    }

    /**
     * @return int
     */
    public function id(): int
    {
        return $this->id;
    }

    /**
     * @param string $reason
     *
     * @return Task
     */
    public function cancel(string $reason = ''): self
    {
        $this->token->cancel($this->id, $reason);

        return $this;
    }

    /**
     * @param int $timeout
     *
     * @return self
     */
    public function timeout(int $timeout): self
    {
        $deferred = new Deferred;
        $resolved = false;

        $watcher = Loop::delay($timeout, function () use ($deferred, &$resolved) {
            if ($resolved) {
                return;
            }

            $resolved = true;

            $deferred->fail(new Exception\TaskTimeout($this->id));
        });

        $promise = $this->promise;
        $promise->onResolve(function () use ($deferred, $watcher, &$resolved) {
            if ($resolved) {
                return;
            }

            $resolved = true;

            Loop::cancel($watcher);

            $deferred->resolve($this->promise);
        });

        $this->promise = $deferred->promise();

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function onResolve(callable $onResolved)
    {
        $this->token->guard();
        $this->promise->onResolve($onResolved);
    }
}


1		<?php
2		/**
3		* This file is part of PHPinnacle/Ensign.
4		*
5		* (c) PHPinnacle Team <[email protected]>
6		*
7		* For the full copyright and license information, please view the LICENSE
8		* file that was distributed with this source code.
9		*/
10
11		declare(strict_types = 1);
12
13		namespace PHPinnacle\Ensign;
14
15		use Amp\Deferred;
16		use Amp\Loop;
17		use Amp\Promise;
18
19		final class Task implements Promise
20		{
21		/**
22		* @var int
23		*/
24		private $id;
25
26		/**
27		* @var Promise
28		*/
29		private $promise;
30
31		/**
32		* @var Token
33		*/
34		private $token;
35
36		/**
37		* @param int $id
38		* @param Promise $promise
39		* @param Token $token
40		*/
41	12	public function __construct(int $id, Promise $promise, Token $token)
42		{
43	12	$this->id = $id;
44	12	$this->promise = $promise;
45	12	$this->token = $token;
46	12	}
47
48		/**
49		* @return int
50		*/
51	2	public function id(): int
52		{
53	2	return $this->id;
54		}
55
56		/**
57		* @param string $reason
58		*
59		* @return Task
60		*/
61	1	public function cancel(string $reason = ''): self
62		{
63	1	$this->token->cancel($this->id, $reason);
64
65	1	return $this;
66		}
67
68		/**
69		* @param int $timeout
70		*
71		* @return self
72		*/
73	2	public function timeout(int $timeout): self
74		{
75	2	$deferred = new Deferred;
76	2	$resolved = false;
77
78	2	$watcher = Loop::delay($timeout, function () use ($deferred, &$resolved) {
79	1	if ($resolved) {
80		return;
81		}
82
83	1	$resolved = true;
84
85	1	$deferred->fail(new Exception\TaskTimeout($this->id));
86	2	});
87
88	2	$promise = $this->promise;
89	2	$promise->onResolve(function () use ($deferred, $watcher, &$resolved) {
90	1	if ($resolved) {
91	1	return;
92		}
93
94	1	$resolved = true;
95
96	1	Loop::cancel($watcher);
97
98	1	$deferred->resolve($this->promise);
99	2	});
100
101	2	$this->promise = $deferred->promise();
102
103	2	return $this;
104		}
105
106		/**
107		* {@inheritdoc}
108		*/
109	12	public function onResolve(callable $onResolved)
110		{
111	12	$this->token->guard();
112	11	$this->promise->onResolve($onResolved);
113	11	}
114		}
115

phpinnacle / ensign

Push — master ( ca9c7f...904700 )

Task::timeout() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like