League\Event\PrioritizedListenerRegistrar

Complexity

Total Complexity

10

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	subscribeTo()	0	8	2
A	subscribeOnceTo()	0	4	1
A	getListenersForEvent()	0	16	4
A	getListenersForEventName()	0	8	2
A	subscribeListenersFrom()	0	4	1

<?php

declare(strict_types=1);

namespace League\Event;

use Psr\EventDispatcher\ListenerProviderInterface;

class PrioritizedListenerRegistrar implements ListenerRegistrar, ListenerProviderInterface
{
    /** @var array<string,PrioritizedListenersForEvent> */
    protected $listenersPerEvent = [];

    public function subscribeTo(string $event, callable $listener, int $priority = ListenerPriority::NORMAL): void
    {
        $group = array_key_exists($event, $this->listenersPerEvent)
            ? $this->listenersPerEvent[$event]
            : $this->listenersPerEvent[$event] = new PrioritizedListenersForEvent();

        $group->addListener($listener, $priority);
    }

    public function subscribeOnceTo(string $event, callable $listener, int $priority = ListenerPriority::NORMAL): void
    {
        $this->subscribeTo($event, new OneTimeListener($listener), $priority);
    }

    public function getListenersForEvent(object $event): iterable
    {
        /**
         * @var string                       $key
         * @var PrioritizedListenersForEvent $group
         */
        foreach ($this->listenersPerEvent as $key => $group) {
            if ($event instanceof $key) {
                yield from $group->getListeners();
            }
        }

        if ($event instanceof HasEventName) {
            yield from $this->getListenersForEventName($event->eventName());
        }
    }

    private function getListenersForEventName(string $eventName): iterable
    {
        if ( ! array_key_exists($eventName, $this->listenersPerEvent)) {
            return [];
        }

        return $this->listenersPerEvent[$eventName]->getListeners();
    }

    public function subscribeListenersFrom(ListenerSubscriber $subscriber): void
    {
        $subscriber->subscribeListeners($this);
    }
}