Thruster\Component\EventEmitter\AdvanceEventEmitterTrait

Complexity

Total Complexity

12

Size/Duplication

Total Lines	105
Duplicated Lines	22.86 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

6 Methods

Rating	Name	Duplication	Size	Complexity
A	on()	0	6	1
A	once()	12	12	1
A	removeListener()	12	12	3
A	removeListeners()	0	10	2
A	getListeners()	0	4	2
A	emit()	0	14	3

<?php

namespace Thruster\Component\EventEmitter;

/**
 * Trait AdvanceEventEmitterTrait
 *
 * @package Thruster\Component\EventEmitter
 * @author  Aurimas Niekis <aurimas@niekis.lt>
 */
trait AdvanceEventEmitterTrait
{
    /**
     * @var callable[]
     */
    protected $listeners = [];

    /**
     * @param string   $eventName
     * @param callable $listener
     *
     * @return $this
     */
    public function on(string $eventName, callable $listener) : self
    {
        $this->listeners[$eventName][] = $listener;

        return $this;
    }

    /**
     * @param string   $eventName
     * @param callable $listener
     *
     * @return $this
     */
    public function once(string $eventName, callable $listener) : self

This method seems to be duplicated in your project.

    {
        $onceListener = function (EventInterface $event) use (&$onceListener, $eventName, $listener) {
            $this->removeListener($eventName, $onceListener);

            call_user_func($listener, $event);
        };

        $this->on($eventName, $onceListener);

        return $this;
    }

    /**
     * @param string   $eventName
     * @param callable $listener
     *
     * @return $this
     */
    public function removeListener(string $eventName, callable $listener) : self

This method seems to be duplicated in your project.

    {
        if (array_key_exists($eventName, $this->listeners)) {
            $index = array_search($listener, $this->listeners[$eventName], true);

            if (false !== $index) {
                unset($this->listeners[$eventName][$index]);
            }
        }

        return $this;
    }

    /**
     * @param string $eventName
     *
     * @return $this
     */
    public function removeListeners(string $eventName = null) : self
    {
        if (null !== $eventName) {
            unset($this->listeners[$eventName]);
        } else {
            $this->listeners = [];
        }

        return $this;
    }

    /**
     * @param string $eventName
     *
     * @return array|callable[]
     */
    public function getListeners(string $eventName) : array
    {
        return isset($this->listeners[$eventName]) ? $this->listeners[$eventName] : [];
    }

    /**
     * @param string         $eventName
     * @param EventInterface $event
     *
     * @return $this
     */
    public function emit(string $eventName, EventInterface $event = null) : self
    {
        $event = $event ?? new Event();

        foreach ($this->getListeners($eventName) as $listener) {
            call_user_func($listener, $event);

            if (true == $event->isPropagationStopped()) {

It seems like you are loosely comparing two booleans. Considering using the strict comparison === instead.

                break;
            }
        }

        return $this;
    }
}