Arp\EventDispatcher\AbstractEventDispatcher

Complexity

Total Complexity

6

Size/Duplication

Total Lines	32
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	isPropagationStopped()	0	3	2
A	dispatch()	0	15	4

<?php

declare(strict_types=1);

namespace Arp\EventDispatcher;

use Psr\EventDispatcher\EventDispatcherInterface;
use Psr\EventDispatcher\ListenerProviderInterface;
use Psr\EventDispatcher\StoppableEventInterface;

abstract class AbstractEventDispatcher implements EventDispatcherInterface
{
    abstract protected function getListenerProvider(): ListenerProviderInterface;

    /**
     * @param object|StoppableEventInterface $event
     *
     * @throws \Throwable
     */
    public function dispatch(object $event): object
    {
        if ($this->isPropagationStopped($event)) {
            return $event;
        }

        foreach ($this->getListenerProvider()->getListenersForEvent($event) as $listener) {
            $listener($event);

            if ($this->isPropagationStopped($event)) {
                break;
            }
        }

        return $event;
    }

    /**
     * @param object|StoppableEventInterface $event
     */
    protected function isPropagationStopped(object $event): bool
    {
        return ($event instanceof StoppableEventInterface && $event->isPropagationStopped());
    }
}