Deferred::runQueue() - Code Metrics - Inspection of "Remove dead code" - webonyx/graphql-php - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#550)

by Jáchym

created 2019-10-03 22:00 UTC

Deferred::runQueue() A

↳ Parent: Deferred

Complexity

Conditions	2
Paths	2

Size

Total Lines	7
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	2

Importance

Changes

Metric	Value
eloc	4
dl	0
loc	7
ccs	5
cts	5
cp	1
rs	10
c	0
b	0
f	0
cc	2
nc	2
nop	0
crap	2

<?php

declare(strict_types=1);

namespace GraphQL;

use Exception;
use GraphQL\Executor\Promise\Adapter\SyncPromise;
use SplQueue;
use Throwable;

class Deferred
{
    /** @var SplQueue|null */
    private static $queue;

    /** @var callable */
    private $callback;

    /** @var SyncPromise */
    public $promise;

    public function __construct(callable $callback)
    {
        $this->callback = $callback;
        $this->promise  = new SyncPromise();
        self::getQueue()->enqueue($this);
    }

    public static function getQueue() : SplQueue
    {
        if (self::$queue === null) {
            self::$queue = new SplQueue();
        }

        return self::$queue;
    }

    public static function runQueue() : void
    {
        $queue = self::getQueue();
        while (! $queue->isEmpty()) {
            /** @var self $dequeuedNodeValue */
            $dequeuedNodeValue = $queue->dequeue();
            $dequeuedNodeValue->run();
        }
    }

    public function then($onFulfilled = null, $onRejected = null)
    {
        return $this->promise->then($onFulfilled, $onRejected);
    }

    public function run() : void
    {
        try {
            $cb = $this->callback;
            $this->promise->resolve($cb());
        } catch (Throwable $e) {
            $this->promise->reject($e);
        }
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace GraphQL;
6
7		use Exception;
8		use GraphQL\Executor\Promise\Adapter\SyncPromise;
9		use SplQueue;
10		use Throwable;
11
12		class Deferred
13		{
14		/** @var SplQueue\|null */
15		private static $queue;
16
17		/** @var callable */
18		private $callback;
19
20		/** @var SyncPromise */
21		public $promise;
22
23	43	public function __construct(callable $callback)
24		{
25	43	$this->callback = $callback;
26	43	$this->promise = new SyncPromise();
27	43	self::getQueue()->enqueue($this);
28	43	}
29
30	241	public static function getQueue() : SplQueue
31		{
32	241	if (self::$queue === null) {
33	1	self::$queue = new SplQueue();
34		}
35
36	241	return self::$queue;
37		}
38
39	65	public static function runQueue() : void
40		{
41	65	$queue = self::getQueue();
42	65	while (! $queue->isEmpty()) {
43		/** @var self $dequeuedNodeValue */
44	40	$dequeuedNodeValue = $queue->dequeue();
45	40	$dequeuedNodeValue->run();
46		}
47	65	}
48
49	1	public function then($onFulfilled = null, $onRejected = null)
50		{
51	1	return $this->promise->then($onFulfilled, $onRejected);
52		}
53
54	40	public function run() : void
55		{
56		try {
57	40	$cb = $this->callback;
58	40	$this->promise->resolve($cb());
59	18	} catch (Throwable $e) {
60	18	$this->promise->reject($e);
61		}
62	40	}
63		}
64

webonyx / graphql-php

Pull Request — master (#550)

Deferred::runQueue() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like