| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179 | <?php/* * This file is part of the Symfony package. * * (c) Fabien Potencier <fabien@symfony.com> * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */namespace Symfony\Component\EventDispatcher;/** * The EventDispatcherInterface is the central point of Symfony's event listener system. * * Listeners are registered on the manager and events are dispatched through the * manager. * * @author Guilherme Blanco <guilhermeblanco@hotmail.com> * @author Jonathan Wage <jonwage@gmail.com> * @author Roman Borschel <roman@code-factory.org> * @author Bernhard Schussek <bschussek@gmail.com> * @author Fabien Potencier <fabien@symfony.com> * @author Jordi Boggiano <j.boggiano@seld.be> * @author Jordan Alliot <jordan.alliot@gmail.com> * * @api */class EventDispatcher implements EventDispatcherInterface{    private $listeners = array();    private $sorted = array();    /**     * {@inheritdoc}     */    public function dispatch($eventName, Event $event = null)    {        if (null === $event) {            $event = new Event();        }        $event->setDispatcher($this);        $event->setName($eventName);        if ($listeners = $this->getListeners($eventName)) {            $this->doDispatch($listeners, $eventName, $event);        }        return $event;    }    /**     * {@inheritdoc}     */    public function getListeners($eventName = null)    {        if (null !== $eventName) {            if (!isset($this->listeners[$eventName])) {                return array();            }            if (!isset($this->sorted[$eventName])) {                $this->sortListeners($eventName);            }            return $this->sorted[$eventName];        }        foreach ($this->listeners as $eventName => $eventListeners) {            if (!isset($this->sorted[$eventName])) {                $this->sortListeners($eventName);            }        }        return array_filter($this->sorted);    }    /**     * {@inheritdoc}     */    public function hasListeners($eventName = null)    {        return (bool) count($this->getListeners($eventName));    }    /**     * {@inheritdoc}     */    public function addListener($eventName, $listener, $priority = 0)    {        $this->listeners[$eventName][$priority][] = $listener;        unset($this->sorted[$eventName]);    }    /**     * {@inheritdoc}     */    public function removeListener($eventName, $listener)    {        if (!isset($this->listeners[$eventName])) {            return;        }        foreach ($this->listeners[$eventName] as $priority => $listeners) {            if (false !== ($key = array_search($listener, $listeners, true))) {                unset($this->listeners[$eventName][$priority][$key], $this->sorted[$eventName]);            }        }    }    /**     * {@inheritdoc}     */    public function addSubscriber(EventSubscriberInterface $subscriber)    {        foreach ($subscriber->getSubscribedEvents() as $eventName => $params) {            if (is_string($params)) {                $this->addListener($eventName, array($subscriber, $params));            } elseif (is_string($params[0])) {                $this->addListener($eventName, array($subscriber, $params[0]), isset($params[1]) ? $params[1] : 0);            } else {                foreach ($params as $listener) {                    $this->addListener($eventName, array($subscriber, $listener[0]), isset($listener[1]) ? $listener[1] : 0);                }            }        }    }    /**     * {@inheritdoc}     */    public function removeSubscriber(EventSubscriberInterface $subscriber)    {        foreach ($subscriber->getSubscribedEvents() as $eventName => $params) {            if (is_array($params) && is_array($params[0])) {                foreach ($params as $listener) {                    $this->removeListener($eventName, array($subscriber, $listener[0]));                }            } else {                $this->removeListener($eventName, array($subscriber, is_string($params) ? $params : $params[0]));            }        }    }    /**     * Triggers the listeners of an event.     *     * This method can be overridden to add functionality that is executed     * for each listener.     *     * @param callable[] $listeners The event listeners.     * @param string     $eventName The name of the event to dispatch.     * @param Event      $event     The event object to pass to the event handlers/listeners.     */    protected function doDispatch($listeners, $eventName, Event $event)    {        foreach ($listeners as $listener) {            call_user_func($listener, $event, $eventName, $this);            if ($event->isPropagationStopped()) {                break;            }        }    }    /**     * Sorts the internal list of listeners for the given event by priority.     *     * @param string $eventName The name of the event.     */    private function sortListeners($eventName)    {        $this->sorted[$eventName] = array();        krsort($this->listeners[$eventName]);        $this->sorted[$eventName] = call_user_func_array('array_merge', $this->listeners[$eventName]);    }}
 |