carno-php / consul

src/KVStore.php

Spacing +2 added lines, -2 removed lines

@@ -29,11 +29,11 @@
     {
         $path = $keys === '*' ? $folder : sprintf('%s/%s', $folder, $keys);
 
-        $ig = function () use ($path) {
+        $ig = function() use ($path) {
             return (new KVGetting($this->agent))->path($path);
         };
 
-        $do = function (KVGetting $lister) use ($notify) {
+        $do = function(KVGetting $lister) use ($notify) {
             yield $notify->send($this->changed(yield $lister->result()));
         };
 

src/Features/Keepalive.php

Spacing +1 added lines, -1 removed lines

@@ -56,7 +56,7 @@
      */
     private function start(int $heartbeat) : void
     {
-        $this->daemon = Timer::loop($heartbeat * 1000, co(function () {
+        $this->daemon = Timer::loop($heartbeat * 1000, co(function() {
             yield $this->updating();
         }));
 

src/Discovery.php

Spacing +2 added lines, -2 removed lines

@@ -32,11 +32,11 @@
      */
     public function watching(string $service, Chan $notify) : void
     {
-        $ig = function () use ($service) {
+        $ig = function() use ($service) {
             return $this->endpointsLister($service);
         };
 
-        $do = function (AbstractEndpointsLister $lister) use ($notify) {
+        $do = function(AbstractEndpointsLister $lister) use ($notify) {
             yield $notify->send($this->routing(yield $lister->result()));
         };
 

src/Registry.php

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
             )->setKeepalive($heartbeat)
         ;
 
-        async(static function (Agent $agent, Service $service) {
+        async(static function(Agent $agent, Service $service) {
             for (;;) {
                 /**
                  * @var Result $registered

src/Chips/SRegister.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
      */
     public function connected() : bool
     {
-        return !! $this->assignedAgent;
+        return !!$this->assignedAgent;
     }
 
     /**

src/Chips/SVersions.php

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
      */
     public function hasVersion() : bool
     {
-        return ! is_null($this->versionIDX);
+        return !is_null($this->versionIDX);
     }
 
     /**

src/Chips/SDeregister.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
      */
     public function deregister() : Promised
     {
-        return async(function (Service $service) {
+        return async(function(Service $service) {
             for (;;) {
                 if (!$service->connected()) {
                     logger('consul')->info('Service has not been registered .. skip', ['svc' => $service->id()]);

src/Chips/GWatcher.php

Spacing +2 added lines, -2 removed lines

@@ -31,14 +31,14 @@
      */
     protected function nwProcess(Promised $cc, Closure $ig, Closure $do, string $em, array $ec) : void
     {
-        go(static function () use ($cc, $ig, $do, $em, $ec) {
+        go(static function() use ($cc, $ig, $do, $em, $ec) {
             /**
              * @var Promised $ex
              */
 
             $ex = null;
 
-            $cc->then(function () use (&$ex) {
+            $cc->then(function() use (&$ex) {
                 $ex && $ex->pended() && $ex->resolve();
             });
 

src/APIs/KVGetting.php

Spacing +2 added lines, -2 removed lines

@@ -47,11 +47,11 @@
      */
     public function result()
     {
-        return $this->perform($this->getCanceller())->then(function (Response $response) {
+        return $this->perform($this->getCanceller())->then(function(Response $response) {
             $kvs = new KVs(
                 $this->path,
                 $response->getStatusCode() === 200
-                    ? $this->decodeResponse((string)$response->getBody())
+                    ? $this->decodeResponse((string) $response->getBody())
                     : []
             );