Viewing file:  EventDispatcher.php (2.31 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
/*
* This file is part of the PHPFlasher package.
* (c) Younes KHOUBZA <younes.khoubza@gmail.com>
*/
namespace Flasher\Prime\EventDispatcher;
use Flasher\Prime\EventDispatcher\Event\StoppableEventInterface;
use Flasher\Prime\EventDispatcher\EventListener\AddToStorageListener;
use Flasher\Prime\EventDispatcher\EventListener\EventSubscriberInterface;
use Flasher\Prime\EventDispatcher\EventListener\RemoveListener;
use Flasher\Prime\EventDispatcher\EventListener\StampsListener;
final class EventDispatcher implements EventDispatcherInterface
{
/**
* @var array<string, EventSubscriberInterface[]>
*/
private $listeners = array();
public function __construct()
{
$this->addSubscriber(new RemoveListener());
$this->addSubscriber(new StampsListener());
$this->addSubscriber(new AddToStorageListener());
}
/**
* {@inheritdoc}
*/
public function dispatch($event)
{
$listeners = $this->getListeners(\get_class($event));
$this->callListeners($listeners, $event); // @phpstan-ignore-line
return $event;
}
/**
* {@inheritdoc}
*/
public function addListener($eventName, $listener)
{
$this->listeners[$eventName][] = $listener; // @phpstan-ignore-line
}
/**
* {@inheritdoc}
*/
public function addSubscriber(EventSubscriberInterface $subscriber)
{
foreach ((array) $subscriber->getSubscribedEvents() as $eventName) {
$this->addListener($eventName, array($subscriber, '__invoke')); // @phpstan-ignore-line
}
}
/**
* @param string $eventName
*
* @return array<int, EventSubscriberInterface[]>
*/
public function getListeners($eventName)
{
if (\array_key_exists($eventName, $this->listeners)) {
return $this->listeners[$eventName]; // @phpstan-ignore-line
}
return array();
}
/**
* @param callable[] $listeners
* @param object $event
*
* @return void
*/
private function callListeners(array $listeners, $event)
{
foreach ($listeners as $listener) {
if ($event instanceof StoppableEventInterface && $event->isPropagationStopped()) {
break;
}
\call_user_func($listener, $event);
}
}
}
|