@@ -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_id($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 | ) |