Action::timeout() - Code Metrics - Inspection of "Parallel experiments" - phpinnacle/ensign - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#6)

by PHPinnacle

created 2018-08-17 16:42 UTC

Action::timeout() A

↳ Parent: Action

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;
use PHPinnacle\Identity\UUID;

final class Action implements Promise
{
    /**
     * @var UUID
     */
    private $id;

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

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

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

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

    /**
     * @param string $reason
     *
     * @return Action
     */
    public function cancel(string $reason = null): self
    {
        $this->token->cancel($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\ActionTimeout((string) $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		use PHPinnacle\Identity\UUID;
19
20		final class Action implements Promise
21		{
22		/**
23		* @var UUID
24		*/
25		private $id;
26
27		/**
28		* @var Promise
29		*/
30		private $promise;
31
32		/**
33		* @var Token
34		*/
35		private $token;
36
37		/**
38		* @param UUID $id
39		* @param Promise $promise
40		* @param Token $token
41		*/
42	11	public function __construct(UUID $id, Promise $promise, Token $token)
43		{
44	11	$this->id = $id;
45	11	$this->promise = $promise;
46	11	$this->token = $token;
47	11	}
48
49		/**
50		* @return UUID
51		*/
52		public function id(): UUID
53		{
54		return $this->id;
55		}
56
57		/**
58		* @param string $reason
59		*
60		* @return Action
61		*/
62	1	public function cancel(string $reason = null): self
63		{
64	1	$this->token->cancel($reason);
65
66	1	return $this;
67		}
68
69		/**
70		* @param int $timeout
71		*
72		* @return self
73		*/
74	2	public function timeout(int $timeout): self
75		{
76	2	$deferred = new Deferred;
77	2	$resolved = false;
78
79	2	$watcher = Loop::delay($timeout, function () use ($deferred, &$resolved) {
80	1	if ($resolved) {
81		return;
82		}
83
84	1	$resolved = true;
85
86	1	$deferred->fail(new Exception\ActionTimeout((string) $this->id));
87	2	});
88
89	2	$promise = $this->promise;
90	2	$promise->onResolve(function () use ($deferred, $watcher, &$resolved) {
91	1	if ($resolved) {
92	1	return;
93		}
94
95	1	$resolved = true;
96
97	1	Loop::cancel($watcher);
98
99	1	$deferred->resolve($this->promise);
100	2	});
101
102	2	$this->promise = $deferred->promise();
103
104	2	return $this;
105		}
106
107		/**
108		* {@inheritdoc}
109		*/
110	11	public function onResolve(callable $onResolved)
111		{
112	11	$this->token->guard();
113	10	$this->promise->onResolve($onResolved);
114	10	}
115		}
116

phpinnacle / ensign

Pull Request — master (#6)

Action::timeout() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like