anomalylabs /
streams-platform
| @@ 79-88 (lines=10) @@ | ||
| 76 | /** |
|
| 77 | * Fire listeners first. |
|
| 78 | */ |
|
| 79 | foreach (array_get(self::$listeners, $trigger, []) as $callback) { |
|
| 80 | ||
| 81 | if (is_string($callback) || $callback instanceof \Closure) { |
|
| 82 | app()->call($callback, $parameters); |
|
| 83 | } |
|
| 84 | ||
| 85 | if ($callback instanceof SelfHandling) { |
|
| 86 | app()->call([$callback, 'handle'], $parameters); |
|
| 87 | } |
|
| 88 | } |
|
| 89 | ||
| 90 | $method = camel_case('on_' . $trigger); |
|
| 91 | ||
| @@ 110-119 (lines=10) @@ | ||
| 107 | } |
|
| 108 | } |
|
| 109 | ||
| 110 | foreach (array_get($this->callbacks, $trigger, []) as $callback) { |
|
| 111 | ||
| 112 | if (is_string($callback) || $callback instanceof \Closure) { |
|
| 113 | app()->call($callback, $parameters); |
|
| 114 | } |
|
| 115 | ||
| 116 | if ($callback instanceof SelfHandling) { |
|
| 117 | app()->call([$callback, 'handle'], $parameters); |
|
| 118 | } |
|
| 119 | } |
|
| 120 | ||
| 121 | return $this; |
|
| 122 | } |
|
