Homec4science
Diffusion libphutil (production) Browse

libphutil/src/events/PhutilEventEngine.php
3ff84448a916production

Last Change
Raw File

PhutilEventEngine.php
View Options

<?php
final class PhutilEventEngine extends Phobject {
private static $instance;
private $listeners = array();
private function __construct() {
// <empty>
}
public static function getInstance() {
if (!self::$instance) {
self::$instance = new PhutilEventEngine();
}
return self::$instance;
}
public function addListener(PhutilEventListener $listener, $type) {
$this->listeners[$type][] = $listener;
return $this;
}
/**
* Get all the objects currently listening to any event.
*/
public function getAllListeners() {
$listeners = array_mergev($this->listeners);
$listeners = mpull($listeners, null, 'getListenerID');
return $listeners;
}
public static function dispatchEvent(PhutilEvent $event) {
$instance = self::getInstance();
$listeners = idx($instance->listeners, $event->getType(), array());
$global_listeners = idx(
$instance->listeners,
PhutilEventType::TYPE_ALL,
array());
// Merge and deduplicate listeners (we want to send the event to each
// listener only once, even if it satisfies multiple criteria for the
// event).
$listeners = array_merge($listeners, $global_listeners);
$listeners = mpull($listeners, null, 'getListenerID');
$profiler = PhutilServiceProfiler::getInstance();
$profiler_id = $profiler->beginServiceCall(
array(
'type' => 'event',
'kind' => $event->getType(),
'count' => count($listeners),
));
$caught = null;
try {
foreach ($listeners as $listener) {
if ($event->isStopped()) {
// Do this first so if someone tries to dispatch a stopped event it
// doesn't go anywhere. Silly but less surprising.
break;
}
$listener->handleEvent($event);
}
} catch (Exception $ex) {
$profiler->endServiceCall($profiler_id, array());
throw $ex;
}
$profiler->endServiceCall($profiler_id, array());
}
}
c4science · Help