Queue::extract() - Code Metrics - Inspection of "Add basic draft relations implementation" - rambler-digital-solutions/hydrogen - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Push — master ( 1c5165...b7ef6a )

by Kirill

created 2018-09-03 17:14 UTC

Queue::extract() A

↳ Parent: Queue

Complexity

Conditions	4
Paths	3

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	20

Importance

Changes

Metric	Value
dl	0
loc	11
ccs	0
cts	7
cp	0
rs	9.9
c	0
b	0
f	0
cc	4
nc	3
nop	1
crap	20

<?php
/**
 * This file is part of Hydrogen package.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
declare(strict_types=1);

namespace RDS\Hydrogen\Processor;

/**
 * Class DeferredStack
 */
class Queue implements \IteratorAggregate
{
    /**
     * @var \SplQueue
     */
    private $queue;

    /**
     * Queue constructor.
     */
    public function __construct()
    {
        $this->queue = new \SplQueue();
    }

    /**
     * @param \Closure $deferred
     * @return Queue
     */
    public function push(\Closure $deferred): Queue
    {
        $this->queue->push($deferred);

        return $this;
    }

    /**
     * @return \Generator|\Closure[]
     */
    public function getIterator(): \Generator
    {
        while ($this->queue->count()) {
            yield $this->queue->pop();
        }
    }

    /**
     * @param iterable $result
     * @return \Generator
     */
    public function reduce(iterable $result): \Generator
    {
        foreach ($this->getIterator() as $item) {
            $output = $item($this->extract($result));

            if ($output instanceof \Traversable) {
                yield $output;
            }
        }
    }

    /**
     * @param iterable $result
     * @return \Generator
     */
    private function extract(iterable $result): \Generator
    {
        foreach ($result as $item) {
            if (isset($item[0]) && ! \is_scalar($item[0])) {
                $entity = \array_shift($item);
                yield $entity => $item;
            } else {
                yield $item => [];
            }
        }
    }
}


1		<?php
2		/**
3		* This file is part of Hydrogen package.
4		*
5		* For the full copyright and license information, please view the LICENSE
6		* file that was distributed with this source code.
7		*/
8		declare(strict_types=1);
9
10		namespace RDS\Hydrogen\Processor;
11
12		/**
13		* Class DeferredStack
14		*/
15		class Queue implements \IteratorAggregate
16		{
17		/**
18		* @var \SplQueue
19		*/
20		private $queue;
21
22		/**
23		* Queue constructor.
24		*/
25	30	public function __construct()
26		{
27	30	$this->queue = new \SplQueue();
28	30	}
29
30		/**
31		* @param \Closure $deferred
32		* @return Queue
33		*/
34		public function push(\Closure $deferred): Queue
35		{
36		$this->queue->push($deferred);
37
38		return $this;
39		}
40
41		/**
42		* @return \Generator\|\Closure[]
43		*/
44	30	public function getIterator(): \Generator
45		{
46	30	while ($this->queue->count()) {
47		yield $this->queue->pop();
48		}
49	30	}
50
51		/**
52		* @param iterable $result
53		* @return \Generator
54		*/
55	30	public function reduce(iterable $result): \Generator
56		{
57	30	foreach ($this->getIterator() as $item) {
58		$output = $item($this->extract($result));
59
60		if ($output instanceof \Traversable) {
61		yield $output;
62		}
63		}
64	30	}
65
66		/**
67		* @param iterable $result
68		* @return \Generator
69		*/
70		private function extract(iterable $result): \Generator
71		{
72		foreach ($result as $item) {
73		if (isset($item[0]) && ! \is_scalar($item[0])) {
74		$entity = \array_shift($item);
75		yield $entity => $item;
76		} else {
77		yield $item => [];
78		}
79		}
80		}
81		}
82

rambler-digital-solutions / hydrogen

Push — master ( 1c5165...b7ef6a )

Queue::extract() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like