MultiRequestCore::run() - Code Metrics - caoym/phpboot - Measure and Improve Code Quality continuously with Scrutinizer

MultiRequestCore::run() A
last analyzed 2019-10-18 05:28 UTC

↳ Parent: MultiRequestCore

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	2

Importance

Changes

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

<?php

namespace PhpBoot\RPC;

use PhpBoot\Exceptions\RpcException;

class MultiRequestCore
{
    /**
     * MultiRequest constructor.
     * @param callable[] $threads
     * @param callable $waitAll
     */
    public function __construct(array $threads, callable $waitAll)
    {
        foreach ($threads as $thread){
            $pos = count($this->threadResults);
            $this->threadResults[] = [null,null];
            $this->threads[] = function ()use($thread, $pos){
                try{
                    $this->threadResults[$pos][0] = $thread();
                }catch (\Exception $e){
                    $this->threadResults[$pos][1] = $e;
                }
            };
        }
        $this->waitAll = $waitAll;
    }

    public function run()
    {
        while ($thread = array_pop($this->threads)){
            $thread();
        };
    }

    public function wait($waitAble){
        array_push($this->waits, $waitAble);
        $this->run();

        if(count($this->waits)){
            $waitAll = $this->waitAll;
            $this->waitResults = $waitAll($this->waits);
            $this->waits = [];
        }

        $res =  array_pop($this->waitResults);
        if(isset($res[1])){
             \PhpBoot\abort(new RpcException($res['reason']));
        }else{
            return $res[0];
        }
    }

    /**
     * @return array
     */
    public function getResults()
    {
        return $this->threadResults;
    }

    /**
     * @var callable[]
     */
    protected $waits = [];

    /**
     * @var callable[]
     */
    protected $threads = [];

    protected $threadResults = [];
    /**
     * @var callable
     */
    protected $waitAll;

    /**
     * @var callable
     */
    protected $waitResults = [];
}

1		<?php
2
3		namespace PhpBoot\RPC;
4
5		use PhpBoot\Exceptions\RpcException;
6
7		class MultiRequestCore
8		{
9		/**
10		* MultiRequest constructor.
11		* @param callable[] $threads
12		* @param callable $waitAll
13		*/
14	3	public function __construct(array $threads, callable $waitAll)
15		{
16	3	foreach ($threads as $thread){
17	3	$pos = count($this->threadResults);
18	3	$this->threadResults[] = [null,null];
19	3	$this->threads[] = function ()use($thread, $pos){
20		try{
21	3	$this->threadResults[$pos][0] = $thread();
22	3	}catch (\Exception $e){
23	1	$this->threadResults[$pos][1] = $e;
24		}
25	3	};
26	3	}
27	3	$this->waitAll = $waitAll;
28	3	}
29
30	3	public function run()
31		{
32	3	while ($thread = array_pop($this->threads)){
33	3	$thread();
34	3	};
35	3	}
36
37	2	public function wait($waitAble){
38	2	array_push($this->waits, $waitAble);
39	2	$this->run();
40
41	2	if(count($this->waits)){
42	2	$waitAll = $this->waitAll;
43	2	$this->waitResults = $waitAll($this->waits);
44	2	$this->waits = [];
45	2	}
46
47	2	$res = array_pop($this->waitResults);
48	2	if(isset($res[1])){
49		\PhpBoot\abort(new RpcException($res['reason']));
50		}else{
51	2	return $res[0];
52		}
53		}
54
55		/**
56		* @return array
57		*/
58	3	public function getResults()
59		{
60	3	return $this->threadResults;
61		}
62
63		/**
64		* @var callable[]
65		*/
66		protected $waits = [];
67
68		/**
69		* @var callable[]
70		*/
71		protected $threads = [];
72
73		protected $threadResults = [];
74		/**
75		* @var callable
76		*/
77		protected $waitAll;
78
79		/**
80		* @var callable
81		*/
82		protected $waitResults = [];
83		}

caoym / phpboot

GitHub Access Token became invalid

MultiRequestCore::run() A last analyzed 2019-10-18 05:28 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

MultiRequestCore::run() A
last analyzed 2019-10-18 05:28 UTC