1#@!#!123s

: / usr / local / psa / admin / plib / modules / platform360 / vendor / league / event / src /
Filename : EventDispatcher.php
back
<?php

declare (strict_types=1);
namespace Platform360\League\Event;

use Platform360\Psr\EventDispatcher\ListenerProviderInterface;
use Platform360\Psr\EventDispatcher\StoppableEventInterface;
class EventDispatcher implements EventDispatchingListenerRegistry
{
    /**
     * @var ListenerProviderInterface
     */
    protected $listenerProvider;
    public function __construct(?ListenerProviderInterface $listenerProvider = null)
    {
        $this->listenerProvider = $listenerProvider instanceof ListenerProviderInterface ? $listenerProvider : new PrioritizedListenerRegistry();
    }
    public function dispatch(object $event) : object
    {
        $listeners = $this->listenerProvider->getListenersForEvent($event);
        $event instanceof StoppableEventInterface ? $this->dispatchStoppableEvent($listeners, $event) : $this->dispatchUnstoppableEvent($listeners, $event);
        return $event;
    }
    public function dispatchGeneratedEvents(EventGenerator $generator) : void
    {
        foreach ($generator->releaseEvents() as $event) {
            $this->dispatch($event);
        }
    }
    private function dispatchStoppableEvent(iterable $listeners, StoppableEventInterface $event) : void
    {
        foreach ($listeners as $listener) {
            if ($event->isPropagationStopped()) {
                break;
            }
            $listener($event);
        }
    }
    private function dispatchUnstoppableEvent(iterable $listeners, object $event) : void
    {
        foreach ($listeners as $listener) {
            $listener($event);
        }
    }
    public function subscribeTo(string $event, callable $listener, int $priority = ListenerPriority::NORMAL) : void
    {
        if (!$this->listenerProvider instanceof ListenerRegistry) {
            throw UnableToSubscribeListener::becauseTheListenerProviderDoesNotAcceptListeners($this->listenerProvider);
        }
        $this->listenerProvider->subscribeTo($event, $listener, $priority);
    }
    public function subscribeOnceTo(string $event, callable $listener, int $priority = ListenerPriority::NORMAL) : void
    {
        if (!$this->listenerProvider instanceof ListenerRegistry) {
            throw UnableToSubscribeListener::becauseTheListenerProviderDoesNotAcceptListeners($this->listenerProvider);
        }
        $this->listenerProvider->subscribeOnceTo($event, $listener, $priority);
    }
    public function subscribeListenersFrom(ListenerSubscriber $subscriber) : void
    {
        if (!$this->listenerProvider instanceof ListenerRegistry) {
            throw UnableToSubscribeListener::becauseTheListenerProviderDoesNotAcceptListeners($this->listenerProvider);
        }
        $this->listenerProvider->subscribeListenersFrom($subscriber);
    }
}