Queue::executeImmediate() - Code Metrics - mpyw/php-hyper-builtin-server - Measure and Improve Code Quality continuously with Scrutinizer

Queue::executeImmediate() A
last analyzed 2020-06-02 17:43 UTC

↳ Parent: Queue

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
nc	1
nop	1
dl	0
loc	9
rs	9.9666
c	0
b	0
f	0

<?php

namespace mpyw\HyperBuiltinServer\Internal;

class Queue
{
    protected $processes = [];
    protected $promisors = [];

    public function __construct(array $processes)
    {
        if (!$processes) {
            throw new \LengthException('At least 1 process required.');
        }
        array_walk($processes, function (BuiltinServer $process) {
            $this->processes[spl_object_hash($process)] = $process;
        });
    }

    public function executeAsync(\Closure $promisor)
    {
        $this->processes
        ? $this->executeImmediate($promisor)
        : $this->executeReserved($promisor);
    }

    protected function executeImmediate(\Closure $promisor)
    {
        $process = current($this->processes);
        unset($this->processes[spl_object_hash($process)]);
        $promisor($process)->always(function () use ($process) {
            $this->processes[spl_object_hash($process)] = $process;
            $this->dequeue();
        });
    }

    protected function executeReserved(\Closure $promisor)
    {
        $this->promisors[] = $promisor;
    }

    protected function dequeue()
    {
        if ($promisor = array_shift($this->promisors)) {
            $this->executeImmediate($promisor);
        }
    }
}


1			<?php
2
3			namespace mpyw\HyperBuiltinServer\Internal;
4
5			class Queue
6			{
7			protected $processes = [];
8			protected $promisors = [];
9
10			public function __construct(array $processes)
11			{
12			if (!$processes) {
13			throw new \LengthException('At least 1 process required.');
14			}
15			array_walk($processes, function (BuiltinServer $process) {
16			$this->processes[spl_object_hash($process)] = $process;
17			});
18			}
19
20			public function executeAsync(\Closure $promisor)
21			{
22			$this->processes
23			? $this->executeImmediate($promisor)
24			: $this->executeReserved($promisor);
25			}
26
27			protected function executeImmediate(\Closure $promisor)
28			{
29			$process = current($this->processes);
30			unset($this->processes[spl_object_hash($process)]);
31			$promisor($process)->always(function () use ($process) {
32			$this->processes[spl_object_hash($process)] = $process;
33			$this->dequeue();
34			});
35			}
36
37			protected function executeReserved(\Closure $promisor)
38			{
39			$this->promisors[] = $promisor;
40			}
41
42			protected function dequeue()
43			{
44			if ($promisor = array_shift($this->promisors)) {
45			$this->executeImmediate($promisor);
46			}
47			}
48			}
49

mpyw / php-hyper-builtin-server

Queue::executeImmediate() A last analyzed 2020-06-02 17:43 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Queue::executeImmediate() A
last analyzed 2020-06-02 17:43 UTC