1 | <?php |
||
12 | final class ProjectEnabledDispatcher implements EventDispatcher |
||
13 | { |
||
14 | /** |
||
15 | * @var array |
||
16 | */ |
||
17 | private $listeners = []; |
||
18 | |||
19 | /** |
||
20 | * @var array |
||
21 | */ |
||
22 | private $sorted = []; |
||
23 | |||
24 | /** |
||
25 | * @param string $eventName |
||
26 | * @param array $arguments |
||
27 | * @param bool $runProjectionsOnly |
||
28 | */ |
||
29 | 24 | public function dispatch($eventName, array $arguments, $runProjectionsOnly = false) |
|
30 | { |
||
31 | 24 | if (!isset($this->listeners[$eventName])) { |
|
32 | 3 | return; |
|
33 | } |
||
34 | 21 | foreach ($this->getListenersInOrder($eventName) as $listener) { |
|
35 | 21 | call_user_func_array($listener, $arguments); |
|
36 | } |
||
37 | 21 | } |
|
38 | |||
39 | /** |
||
40 | * @param string $eventName |
||
41 | * @param callable $callable |
||
42 | * @param int $priority |
||
43 | */ |
||
44 | 24 | public function addListener($eventName, callable $callable, $priority = 0) |
|
51 | |||
52 | |||
53 | /** |
||
54 | * @param Subscriber $subscriber |
||
55 | * @return void |
||
56 | */ |
||
57 | 6 | public function addSubscriber(Subscriber $subscriber) |
|
58 | { |
||
59 | 6 | foreach ($subscriber->getSubscribedEvents() as $eventName => $params) { |
|
60 | 6 | if (is_string($params)) { |
|
61 | 3 | $this->addListener($eventName, array($subscriber, $params)); |
|
62 | 6 | } elseif (is_string($params[0])) { |
|
63 | 6 | $this->addListener($eventName, array($subscriber, $params[0]), isset($params[1]) ? $params[1] : 0); |
|
64 | } else { |
||
65 | 3 | foreach ($params as $listener) { |
|
66 | 6 | $this->addListener($eventName, array($subscriber, $listener[0]), isset($listener[1]) ? $listener[1] : 0); |
|
67 | } |
||
68 | } |
||
69 | } |
||
70 | 6 | } |
|
71 | |||
72 | /** |
||
73 | * @param $eventName |
||
74 | * @return array |
||
75 | */ |
||
76 | 21 | protected function getListenersInOrder($eventName) |
|
77 | { |
||
78 | 21 | if (!isset($this->listeners[$eventName])) { |
|
79 | return []; |
||
80 | } |
||
81 | 21 | if (!isset($this->sorted[$eventName])) { |
|
82 | 21 | $this->sortListeners($eventName); |
|
83 | } |
||
84 | |||
85 | 21 | return $this->sorted[$eventName]; |
|
86 | } |
||
87 | |||
88 | /** |
||
89 | * Sorts the internal list of listeners for the given event by priority. |
||
90 | * |
||
91 | * @param string $eventName The name of the event. |
||
92 | */ |
||
93 | 21 | private function sortListeners($eventName) |
|
100 | } |