PHPDaemon\Structures\StackCallbacks

Complexity

Total Complexity

17

Size/Duplication

Total Lines	111
Duplicated Lines	21.62 %

Coupling/Cohesion

Components	1
Dependencies	3

7 Methods

Rating	Name	Duplication	Size	Complexity
A	push()	0	4	1
A	unshift()	0	4	1
A	executeOne()	13	14	4
A	executeAndKeepOne()	11	12	3
A	executeAll()	0	18	4
A	toArray()	0	8	2
A	reset()	0	6	2

<?php
namespace PHPDaemon\Structures;

use PHPDaemon\Core\CallbackWrapper;

/**
 * StackCallbacks
 * @package PHPDaemon\Structures
 * @author  Vasily Zorin <maintainer@daemon.io>
 */
class StackCallbacks extends \SplStack
{
    use \PHPDaemon\Traits\ClassWatchdog;
    use \PHPDaemon\Traits\StaticObjectWatchdog;

    /**
     * Push callback to the bottom of stack
     * @param  callable $cb Callback
     * @return void
     */
    public function push($cb)
    {
        parent::push(CallbackWrapper::wrap($cb));
    }

    /**
     * Push callback to the top of stack
     * @param  callable $cb Callback
     * @return void
     */
    public function unshift($cb)
    {
        parent::unshift(CallbackWrapper::wrap($cb));
    }

    /**
     * Executes one callback from the top with given arguments
     * @param  mixed   ...$args Arguments
     * @return boolean
     */
    public function executeOne()

This method seems to be duplicated in your project.

    {
        if ($this->isEmpty()) {
            return false;
        }
        $cb = $this->shift();
        if ($cb) {
            $cb(...func_get_args());
            if ($cb instanceof CallbackWrapper) {
                $cb->cancel();
            }
        }
        return true;
    }

    /**
     * Executes one callback from the top with given arguments without taking it out
     * @param  mixed   ...$args Arguments
     * @return boolean
     */
    public function executeAndKeepOne()

This method seems to be duplicated in your project.

    {
        if ($this->isEmpty()) {
            return false;
        }
        $cb = $this->shift();
        $this->unshift($cb);

$cb is of type *, but the function expects a callable.

        if ($cb) {
            $cb(...func_get_args());
        }
        return true;
    }

    /**
     * Executes all callbacks with given arguments
     * @param array $args
     * @return int
     */
    public function executeAll(...$args)
    {
        if ($this->isEmpty()) {
            return 0;
        }

        $n = 0;
        
        foreach ($this as $cb) {
            $cb(...$args);
            ++$n;
            if ($cb instanceof CallbackWrapper) {
                $cb->cancel();
            }
        }

        return $n;
    }

    /**
     * Return array
     * @return array
     */
    public function toArray()
    {
        $arr = [];
        while (!$this->isEmpty()) {
            $arr[] = $this->shift();
        }
        return $arr;
    }

    /**
     * Shifts all callbacks sequentially
     * @return void
     */
    public function reset()
    {
        while (!$this->isEmpty()) {
            $this->shift();
        }
    }
}