@@ -69,11 +69,11 @@ discard block |
||
| 69 | 69 | |
| 70 | 70 | (new KVStore($this->agent))->watching($dir, self::KEYS, $this->chan = new Channel); |
| 71 | 71 | |
| 72 | - ($await = Promise::deferred())->then(static function () use ($dir) { |
|
| 72 | + ($await = Promise::deferred())->then(static function() use ($dir) { |
|
| 73 | 73 | logger('config')->info('Config watcher is connected', ['dir' => $dir]); |
| 74 | 74 | }); |
| 75 | 75 | |
| 76 | - new Worker($this->chan, function (array $changes) use ($await) { |
|
| 76 | + new Worker($this->chan, function(array $changes) use ($await) { |
|
| 77 | 77 | $await->pended() && $await->resolve(); |
| 78 | 78 | foreach ($changes as $key => $value) { |
| 79 | 79 | $this->config->set($key, $value); |
@@ -92,7 +92,7 @@ discard block |
||
| 92 | 92 | |
| 93 | 93 | $this->chan->close(); |
| 94 | 94 | |
| 95 | - ($wait = $this->chan->closed())->then(static function () use ($dir) { |
|
| 95 | + ($wait = $this->chan->closed())->then(static function() use ($dir) { |
|
| 96 | 96 | logger('config')->info('Config watcher is closed', ['dir' => $dir]); |
| 97 | 97 | }); |
| 98 | 98 | |
@@ -48,7 +48,7 @@ |
||
| 48 | 48 | { |
| 49 | 49 | $this->source = $source; |
| 50 | 50 | |
| 51 | - $this->observer = function ($value, string $key) use ($observer) { |
|
| 51 | + $this->observer = function($value, string $key) use ($observer) { |
|
| 52 | 52 | $priority = $this->ordered[$key]; |
| 53 | 53 | if ($priority >= $this->priority) { |
| 54 | 54 | $this->priority = $priority; |
@@ -18,7 +18,7 @@ |
||
| 18 | 18 | */ |
| 19 | 19 | public function joining(Config $upstream) : void |
| 20 | 20 | { |
| 21 | - $upstream->jFollow(function (...$args) { |
|
| 21 | + $upstream->jFollow(function(...$args) { |
|
| 22 | 22 | $this->jWatched(...$args); |
| 23 | 23 | }); |
| 24 | 24 | } |
@@ -70,7 +70,7 @@ |
||
| 70 | 70 | $this->bound[spl_object_id($options)][] = |
| 71 | 71 | $this->watching( |
| 72 | 72 | $prefix.$cKey, |
| 73 | - function ($value) use ($options, $pName) { |
|
| 73 | + function($value) use ($options, $pName) { |
|
| 74 | 74 | $this->syncPTValue($options, $pName, $value); |
| 75 | 75 | } |
| 76 | 76 | ) |