Dazzle\Promise\Helper\CancellationQueue

Complexity

Total Complexity

12

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

96.43%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	12	2
A	getSize()	0	4	1
A	enqueue()	0	14	4
B	drain()	0	26	5

<?php

namespace Dazzle\Promise\Helper;

use Dazzle\Promise\PromiseInterface;
use Error;
use Exception;

class CancellationQueue
{
    /**
     * @var bool
     */
    private $started = false;

    /**
     * @var PromiseInterface[]
     */
    private $queue = [];

    /**
     * @throws Error|Exception
     */
    public function __invoke()
    {
        if ($this->started)
        {
            return null;
        }

        $this->started = true;
        $this->drain();

        return null;
    }

    /**
     * @return int
     */
    public function getSize()
    {
        return count($this->queue);
    }

    /**
     * @param mixed $cancellable
     * @throws Error|Exception
     */
    public function enqueue($cancellable)
    {
        if ($cancellable instanceof PromiseInterface === false)
        {
            return;
        }

        $length = array_push($this->queue, $cancellable);

        if ($this->started && 1 === $length)
        {
            $this->drain();
        }
    }

    /**
     * @throws Error|Exception
     */
    private function drain()
    {
        for ($i = key($this->queue); isset($this->queue[$i]); $i++)
        {
            $cancellable = $this->queue[$i];
            $ex = null;

            try
            {
                $cancellable->cancel();
            }
            catch (Error $ex)

Consider adding a comment why this CATCH block is empty.

            {}
            catch (Exception $ex)

Consider adding a comment why this CATCH block is empty.

            {}

            unset($this->queue[$i]);

            if ($ex)
            {
                throw $ex;
            }
        }

        $this->queue = [];
    }
}