Queue::reduce() - Code Metrics - Inspection of "Completely refactoring" - rambler-digital-solutions/hydrogen - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Push — master ( b17eba...69b436 )

by Kirill

created 2018-09-02 05:44 UTC

Queue::reduce() A

↳ Parent: Queue

Complexity

Conditions	3
Paths	3

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	12

Importance

Changes

Metric	Value
dl	0
loc	10
ccs	0
cts	9
cp	0
rs	9.9332
c	0
b	0
f	0
cc	3
nc	3
nop	1
crap	12

<?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 array $args
     * @return \Generator
     */
    public function reduce(...$args): \Generator
    {
        foreach ($this->getIterator() as $item) {
            $output = $item(...$args);

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


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			public function __construct()
26			{
27			$this->queue = new \SplQueue();
28			}
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			public function getIterator(): \Generator
45			{
46			while ($this->queue->count()) {
47			yield $this->queue->pop();
48			}
49			}
50
51			/**
52			* @param array $args
53			* @return \Generator
54			*/
55			public function reduce(...$args): \Generator
56			{
57			foreach ($this->getIterator() as $item) {
58			$output = $item(...$args);
59
60			if ($output instanceof \Traversable) {
61			yield $output;
62			}
63			}
64			}
65			}
66

rambler-digital-solutions / hydrogen

Push — master ( b17eba...69b436 )

Queue::reduce() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like