@@ -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 | } |
@@ -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 |
@@ -65,12 +65,12 @@ |
||
65 | 65 | $prefix && $prefix .= '/'; |
66 | 66 | foreach ($map as $cKey => $pName) { |
67 | 67 | if (is_array($pName)) { |
68 | - $this->bindPTKeys($options, $prefix . $cKey, $pName); |
|
68 | + $this->bindPTKeys($options, $prefix.$cKey, $pName); |
|
69 | 69 | } else { |
70 | 70 | $this->bound[spl_object_hash($options)][] = |
71 | 71 | $this->watching( |
72 | - $prefix . $cKey, |
|
73 | - function ($value) use ($options, $pName) { |
|
72 | + $prefix.$cKey, |
|
73 | + function($value) use ($options, $pName) { |
|
74 | 74 | $this->syncPTValue($options, $pName, $value); |
75 | 75 | } |
76 | 76 | ) |