PhpBoot\RPC\MultiRequestCore

Complexity

Total Complexity

9

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

90.91%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	15	3
A	run()	0	6	2
A	wait()	0	17	3
A	getResults()	0	4	1

<?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 = [];
}