Thruster\Component\EventEmitter\EventEmitterTrait

Complexity

Total Complexity

11

Size/Duplication

Total Lines	99
Duplicated Lines	24.24 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

6 Methods

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

<?php

namespace Thruster\Component\EventEmitter;

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

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

        return $this;
    }

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

This method seems to be duplicated in your project.

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

            call_user_func_array($listener, func_get_args());
        };

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

        return $this;
    }

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

This method seems to be duplicated in your project.

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

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

        return $this;
    }

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

        return $this;
    }

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

    /**
     * @param string $event
     * @param array  $arguments
     *
     * @return $this
     */
    public function emit(string $event, array $arguments = []) : self
    {
        foreach ($this->getListeners($event) as $listener) {
            call_user_func_array($listener, $arguments);
        }

        return $this;
    }
}