���ѧۧݧ�ӧ�� �ާ֧ߧ֧էا֧� - ���֧էѧܧ�ڧ��ӧѧ�� - /home/rickpfrv/drive.rickard.co/systemMYs/classes/vendor/League/Event/Emitter.php
���ѧ٧ѧ�
<?php namespace League\Event; use InvalidArgumentException; class Emitter implements EmitterInterface { /** * The registered listeners. * * @var array */ protected $listeners = array(); /** * The sorted listeners * * Listeners will get sorted and stored for re-use. * * @var ListenerInterface[] */ protected $sortedListeners = array(); /** * {@inheritdoc} */ public function addListener($event, $listener, $priority = self::P_NORMAL) { $listener = $this->ensureListener($listener); if (! isset($this->listeners[$event])) { $this->listeners[$event] = array(); } $this->listeners[$event][] = array($listener, $priority); $this->clearSortedListeners($event); return $this; } /** * {@inheritdoc} */ public function addOneTimeListener($event, $listener, $priority = self::P_NORMAL) { $listener = $this->ensureListener($listener); $listener = new OneTimeListener($listener); return $this->addListener($event, $listener, $priority); } /** * {@inheritdoc} */ public function useListenerProvider(ListenerProviderInterface $provider) { $acceptor = new ListenerAcceptor($this); $provider->provideListeners($acceptor); return $this; } /** * {@inheritdoc} */ public function removeListener($event, $listener) { $listeners = array(); if ($this->hasListeners($event)) { $listeners = $this->listeners[$event]; } $filter = function ($registered) use ($listener) { return ! $registered[0]->isListener($listener); }; $this->listeners[$event] = array_filter($listeners, $filter); $this->clearSortedListeners($event); return $this; } /** * {@inheritdoc} */ public function removeAllListeners($event) { $this->clearSortedListeners($event); if ($this->hasListeners($event)) { unset($this->listeners[$event]); } return $this; } /** * Ensure the input is a listener. * * @param ListenerInterface|callable $listener * * @throws InvalidArgumentException * * @return ListenerInterface */ protected function ensureListener($listener) { if ($listener instanceof ListenerInterface) { return $listener; } if (is_callable($listener)) { return CallbackListener::fromCallable($listener); } throw new InvalidArgumentException('Listeners should be be ListenerInterface, Closure or callable. Received type: '.gettype($listener)); } /** * {@inheritdoc} */ public function hasListeners($event) { if (! isset($this->listeners[$event]) || count($this->listeners[$event]) === 0) { return false; } return true; } /** * {@inheritdoc} */ public function getListeners($event) { if (array_key_exists($event, $this->sortedListeners)) { return $this->sortedListeners[$event]; } return $this->sortedListeners[$event] = $this->getSortedListeners($event); } /** * Get the listeners sorted by priority for a given event. * * @param string $event * * @return ListenerInterface[] */ protected function getSortedListeners($event) { if (! $this->hasListeners($event)) { return array(); } $listeners = $this->listeners[$event]; usort($listeners, function ($a, $b) { return $b[1] - $a[1]; }); return array_map(function ($listener) { return $listener[0]; }, $listeners); } /** * {@inheritdoc} */ public function emit($event) { list($name, $event) = $this->prepareEvent($event); $arguments = array($event) + func_get_args(); $this->invokeListeners($name, $event, $arguments); $this->invokeListeners('*', $event, $arguments); return $event; } /** * {@inheritdoc} */ public function emitBatch(array $events) { $emit = array($this, 'emit'); return array_map($emit, $events); } /** * {@inheritdoc} */ public function emitGeneratedEvents(GeneratorInterface $generator) { $events = $generator->releaseEvents(); return $this->emitBatch($events); } /** * Invoke the listeners for an event. * * @param string $name * @param EventInterface $event * @param array $arguments * * @return void */ protected function invokeListeners($name, EventInterface $event, array $arguments) { $listeners = $this->getListeners($name); foreach ($listeners as $listener) { if ($event->isPropagationStopped()) { break; } call_user_func_array(array($listener, 'handle'), $arguments); } } /** * Prepare an event for emitting. * * @param string|EventInterface $event * * @return array */ protected function prepareEvent($event) { $event = $this->ensureEvent($event); $name = $event->getName(); $event->setEmitter($this); return array($name, $event); } /** * Ensure event input is of type EventInterface or convert it. * * @param string|EventInterface $event * * @throws InvalidArgumentException * * @return EventInterface */ protected function ensureEvent($event) { if (is_string($event)) { return Event::named($event); } if (! $event instanceof EventInterface) { throw new InvalidArgumentException('Events should be provides as Event instances or string, received type: '.gettype($event)); } return $event; } /** * Clear the sorted listeners for an event * * @param $event */ protected function clearSortedListeners($event) { if (isset($this->sortedListeners[$event])) { unset($this->sortedListeners[$event]); } } }
| ver. 1.4 |
Github
|
.
| PHP 7.4.33 | ���֧ߧ֧�ѧ�ڧ� ����ѧߧڧ��: 0 |
proxy
|
phpinfo
|
���ѧ����ۧܧ�