carno-php / hrpca

src/Marking.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
      */
     public static function viaTCP(int $port) : string
     {
-        return Tags::CMD . sprintf('%s:%s::%d', Named::KEY, Named::TCP, $port);
+        return Tags::CMD.sprintf('%s:%s::%d', Named::KEY, Named::TCP, $port);
     }
 
     /**

src/Server.php

Spacing +2 added lines, -2 removed lines

@@ -116,9 +116,9 @@
             return;
         }
 
-        $this->reconcile->wait($idx = $this->seq())->message()->then(function (string $message) use ($seq, $socket) {
+        $this->reconcile->wait($idx = $this->seq())->message()->then(function(string $message) use ($seq, $socket) {
             return $socket->write($this->packing($seq, $message));
-        }, static function () use ($socket) {
+        }, static function() use ($socket) {
             return $socket->close();
         });
 

src/Client.php

Spacing +1 added lines, -1 removed lines

@@ -56,7 +56,7 @@
         $this->address = $address = new Address($endpoint->address()->host(), $endpoint->option(Named::VIA_TCP));
         $this->options = $options;
 
-        $this->sockets = new Pool($options->pooling(), static function () use ($address) {
+        $this->sockets = new Pool($options->pooling(), static function() use ($address) {
             return new Socket($address);
         }, $options->identify());
     }

src/Chips/Protocol.php

Spacing +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
      */
     protected function packing(int $seq, string $message) : string
     {
-        return pack('N', $seq) . pack('N', strlen($message)) . $message;
+        return pack('N', $seq).pack('N', strlen($message)).$message;
     }
 
     /**

src/Chips/Sequence.php

Spacing +1 added lines, -1 removed lines

@@ -20,6 +20,6 @@
      */
     protected function seq() : int
     {
-        return $this->seq ++ > 0xFFFFFFFF ? $this->seq = 1 : $this->seq;
+        return $this->seq++ > 0xFFFFFFFF ? $this->seq = 1 : $this->seq;
     }
 }

src/Transport/Socket.php

Spacing +5 added lines, -5 removed lines

@@ -68,16 +68,16 @@ 
         $this->socket = Sock::connect(
             $this->connect,
             (new Events)
-            ->attach(Events\Socket::CONNECTED, function () {
+            ->attach(Events\Socket::CONNECTED, function() {
                 $this->connected->resolve();
             })
-            ->attach(Events\Socket::RECEIVED, function (Stream $conn) {
+            ->attach(Events\Socket::RECEIVED, function(Stream $conn) {
                 $this->reconciled->done(...$this->unpacking($conn->recv()));
             })
-            ->attach(Events\Socket::CLOSED, function () {
+            ->attach(Events\Socket::CLOSED, function() {
                 $this->closed()->resolve();
             })
-            ->attach(Events\Socket::ERROR, function () {
+            ->attach(Events\Socket::ERROR, function() {
                 $this->closed()->resolve();
             }),
             new Options(Config::SW_PACKAGE, Config::SW_SOCKET)
@@ -108,7 +108,7 @@ 
      */
     private function cleanup() : Promised
     {
-        ($w = Promise::deferred())->then(function () {
+        ($w = Promise::deferred())->then(function() {
             $this->reconciled->shutdown(new TransportNowClosedException);
         });
         return $w;

src/Transport/Packet.php

Spacing +1 added lines, -1 removed lines

@@ -81,7 +81,7 @@
      */
     private function cleanup() : Promised
     {
-        return Promise::deferred()->catch(function () {
+        return Promise::deferred()->catch(function() {
             $this->from->free($this->seq);
             $this->from = null;
         });

src/Plugins/ServerPorting.php

Spacing +2 added lines, -2 removed lines

@@ -58,7 +58,7 @@ 
     public function hooking(Events $events) : void
     {
         $events
-        ->attach(Events\Server::CREATED, function (Conn $serv) {
+        ->attach(Events\Server::CREATED, function(Conn $serv) {
             ($this->server = new Server($this->listen, $serv->server()->raw(), $serv->events()))->serve();
             if ($port = $this->server->ported()) {
                 /**
@@ -71,7 +71,7 @@ 
                 logger('hrpc-accel')->notice('TCP accelerator startup failed .. skip');
             }
         })
-        ->attach(Events\Worker::STOPPED, function () {
+        ->attach(Events\Worker::STOPPED, function() {
             $this->server->shutdown();
         });
     }