PeekAndPoke\Component\Emitter\EmitterImpl

Complexity

Total Complexity

11

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	enable()	0	3	1
A	emit()	0	14	3
A	isListener()	0	5	3
A	bind()	0	17	4

<?php
/**
 * File was created 19.03.2015 08:39
 *
 * @author Karsten J. Gerber <kontakt@karsten-gerber.de>
 */

namespace PeekAndPoke\Component\Emitter;

use PeekAndPoke\Component\Psi\UnaryFunction;

/**
 * Emitter
 *
 * @author Karsten J. Gerber <kontakt@karsten-gerber.de>
 */
class EmitterImpl implements Emitter
{
    /** @var bool */
    private $enabled = true;

    /** @var \SplObjectStorage[] */
    private $bindings = [];

    /**
     * @param bool $enabled
     */
    public function enable($enabled = true)
    {
        $this->enabled = $enabled;
    }

    /**
     * {@inheritdoc}
     */
    public function bind($eventName, $handler)
    {
        if (! self::isListener($handler)) {
            throw new \LogicException('Invalid listener');
        }

        if (false === array_key_exists($eventName, $this->bindings)) {
            $this->bindings[$eventName] = new \SplObjectStorage();
        }

        $listeners = $this->bindings[$eventName];

        if (! $listeners->offsetExists($handler)) {
            $listeners->offsetSet($handler);
        }

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function emit(Event $event)
    {
        if ($this->enabled === false) {
            return $this;
        }

        /** @var callable[] $listeners */
        $listeners = $this->bindings[$event->getEventName()] ?? [];

        foreach ($listeners as $listener) {
            $listener($event);
        }

        return $this;
    }

    /**
     * @param Listener|UnaryFunction|callable $listener
     *
     * @return bool
     */
    public static function isListener($listener)
    {
        return $listener instanceof \Closure ||
               $listener instanceof Listener ||
               \is_callable($listener);
    }
}