carno-php / hrpc

src/Server.php

Spacing +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
         $this->name = $name;
         $this->listen = $listen;
 
-        $this->events()->attach(Worker::STARTED, function (Conn $ctx) {
+        $this->events()->attach(Worker::STARTED, function(Conn $ctx) {
             $ctx->events()->attach(HTTP::REQUESTING, RServer::layers()->handler());
         });
     }

src/Serviced/ConsulRG.php

Spacing +2 added lines, -2 removed lines

@@ -66,7 +66,7 @@ 
                 ->servicing($advertise, $server, $this->dTagging->getTags())
             ;
 
-            ($ready = $service->ready())->then(static function () use ($service) {
+            ($ready = $service->ready())->then(static function() use ($service) {
                 logger('hrpc')->info('Service has been registered', ['node' => $service->endpoint()]);
             });
 
@@ -84,7 +84,7 @@ 
         $waits = [];
 
         foreach ($this->sRegistered as $service) {
-            ($respond = $service->deregister())->then(static function () use ($service) {
+            ($respond = $service->deregister())->then(static function() use ($service) {
                 logger('hrpc')->info('Service has been deregistered', ['node' => $service->endpoint()]);
             });
             $waits[] = $respond;

src/Handlers/TrafficShaping.php

Spacing +2 added lines, -2 removed lines

@@ -38,7 +38,7 @@ 
         Ticker::new([
             Metrics::gauge()->named('shaper.bucket.tokens'),
             Metrics::gauge()->named('shaper.acquire.waits'),
-        ], static function (Gauge $tokens, Gauge $waits) use ($shaper) {
+        ], static function(Gauge $tokens, Gauge $waits) use ($shaper) {
             $tokens->set($shaper->tokens());
             $waits->set($shaper->waits());
         });
@@ -55,7 +55,7 @@ 
             return $request;
         }
 
-        return $this->shaper->queued()->then(static function () use ($request) {
+        return $this->shaper->queued()->then(static function() use ($request) {
             return $request;
         });
     }

src/Plugins/Registry.php

Spacing +7 added lines, -7 removed lines

@@ -67,7 +67,7 @@ 
      */
     public function enabled() : bool
     {
-        return DI::has(ServiceRG::class) ? !! $this->registry = DI::get(ServiceRG::class) : false;
+        return DI::has(ServiceRG::class) ? !!$this->registry = DI::get(ServiceRG::class) : false;
     }
 
     /**
@@ -80,19 +80,19 @@ 
         $forked->waiting($this->waits);
 
         $events
-        ->attach(Events\Server::CREATED, static function (Conn $serv) use ($forked) {
+        ->attach(Events\Server::CREATED, static function(Conn $serv) use ($forked) {
             $forked->startup($serv->server()->raw());
         })
-        ->attach(Events\Server::STARTUP, static function (Conn $serv) use ($forked) {
+        ->attach(Events\Server::STARTUP, static function(Conn $serv) use ($forked) {
             $forked->porting($serv->local()->port());
         })
-        ->attach(Events\Server::SHUTDOWN, static function () use ($forked) {
+        ->attach(Events\Server::SHUTDOWN, static function() use ($forked) {
             $forked->shutdown();
         })
-        ->attach(Events\Worker::STARTED, static function (Conn $serv) use ($forked) {
+        ->attach(Events\Worker::STARTED, static function(Conn $serv) use ($forked) {
             $startup = $serv->ctx()->get('WG:STARTING');
             if ($startup instanceof Waited) {
-                $startup->done()->then(function () use ($serv, $forked) {
+                $startup->done()->then(function() use ($serv, $forked) {
                     $forked->ready($serv->worker());
                 });
             } else {
@@ -124,7 +124,7 @@ 
      */
     public function ready(int $wid) : void
     {
-        $this->ready ++;
+        $this->ready++;
         $this->starting();
     }
 

src/Components/Scanner.php

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
          * @var RScanner $scanner
          */
 
-        if (defined('CWD') && is_file($rf = CWD . '/registers.php')) {
+        if (defined('CWD') && is_file($rf = CWD.'/registers.php')) {
             DI::set(Router::class, $router = DI::object(Router::class));
             DI::set(RScanner::class, $scanner = DI::object(RScanner::class));
 
@@ -36,7 +36,7 @@ 
 
             $app->named($router->server());
 
-            $app->starting()->add(static function () use ($scanner) {
+            $app->starting()->add(static function() use ($scanner) {
                 $scanner->analyzing();
             });
         }

src/Components/Tracing.php

Spacing +2 added lines, -2 removed lines

@@ -41,12 +41,12 @@
 
         $platform = DI::get(Observer::class);
 
-        $platform->transportable(static function () {
+        $platform->transportable(static function() {
             Server::layers()->has(TracedOutgoing::class)
             || Server::layers()->prepend(ServerWrapper::class, DI::object(TracedOutgoing::class));
             Server::layers()->has(TracedIncoming::class)
             || Server::layers()->append(ServerWrapper::class, DI::object(TracedIncoming::class));
-        }, static function () {
+        }, static function() {
             Server::layers()->remove(TracedOutgoing::class);
             Server::layers()->remove(TracedIncoming::class);
         });

src/Components/Dispatcher.php

Spacing +3 added lines, -3 removed lines

@@ -39,8 +39,8 @@ 
         $started = $app->starting()->done();
         $shutdown = Promise::deferred();
 
-        $app->starting()->add(static function () use ($dispatcher, $started, $shutdown) {
-            $dispatcher->preparing($started, $shutdown)->catch(function (Throwable $e) {
+        $app->starting()->add(static function() use ($dispatcher, $started, $shutdown) {
+            $dispatcher->preparing($started, $shutdown)->catch(function(Throwable $e) {
                 logger('hrpc')->error(
                     'Service startup failed when initialize',
                     ['ec' => get_class($e), 'em' => $e->getMessage()]
@@ -48,7 +48,7 @@ 
             });
         });
 
-        $app->stopping()->add(static function () use ($shutdown) {
+        $app->stopping()->add(static function() use ($shutdown) {
             $shutdown->resolve();
         });
     }

src/Components/Serving.php

Spacing +2 added lines, -2 removed lines

@@ -49,7 +49,7 @@ 
         // initial mark server "unavailable"
         Server::layers()->append(ServerWrapper::class, DI::object(ServerUnavailable::class));
 
-        $app->starting()->add(static function () use ($options) {
+        $app->starting()->add(static function() use ($options) {
             // add traffic monitor layer
             DI::has(Daemon::class) && Server::layers()->append(
                 ServerWrapper::class,
@@ -59,7 +59,7 @@ 
             config()->bind($options, ['rpc.serv.opts' => ['tt.exec' => 'ttExec']]);
         });
 
-        $app->starting()->done()->then(static function () {
+        $app->starting()->done()->then(static function() {
             // mark server "available" when bootstrap done
             Server::layers()->remove(ServerUnavailable::class);
         });