carno-php / http

src/Server.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
         return new NVServer(
             $serviced,
             $listen,
-            (new Events)->attach(Events\HTTP::REQUESTING, function (Connection $conn) use ($processor) {
+            (new Events)->attach(Events\HTTP::REQUESTING, function(Connection $conn) use ($processor) {
                 try {
                     $processor($conn);
                 } catch (Throwable $e) {

src/Client.php

Spacing +8 added lines, -8 removed lines

@@ -89,11 +89,11 @@ 
     public function perform(Request $request, Promised $canceller = null) : Promised
     {
         if ($this->options->pooled()) {
-            return async(function () use ($request, $canceller) {
+            return async(function() use ($request, $canceller) {
                 if ($canceller) {
                     $interrupt = Promise::deferred();
-                    $canceller->then(static function () use ($interrupt) {
-                        $interrupt->then(static function (SWClient $client) {
+                    $canceller->then(static function() use ($interrupt) {
+                        $interrupt->then(static function(SWClient $client) {
                             return $client->close();
                         });
                         $interrupt->resolve();
@@ -109,13 +109,13 @@ 
             });
         }
 
-        return async(function () use ($request, $canceller) {
+        return async(function() use ($request, $canceller) {
             /**
              * @var SWClient $client
              */
             $this->session = $client = yield $this->http($this->remote($request->getUri()), false);
 
-            $canceller && $canceller->then(static function () use ($client) {
+            $canceller && $canceller->then(static function() use ($client) {
                 return $client->close();
             });
 
@@ -154,7 +154,7 @@ 
      */
     public function keepalived(Closure $initialize) : void
     {
-        ($this->ka ?? $this->ka = Promise::deferred())->then(function () use ($initialize) {
+        ($this->ka ?? $this->ka = Promise::deferred())->then(function() use ($initialize) {
             $initialize($this->pool);
         });
     }
@@ -169,11 +169,11 @@ 
             return $this->pool;
         }
 
-        $this->pool = new Pool($this->options->pooling(), function () use ($remote) {
+        $this->pool = new Pool($this->options->pooling(), function() use ($remote) {
             return $this->http($remote, true);
         }, $this->options->identify());
 
-        $this->pool->closed()->then(function () {
+        $this->pool->closed()->then(function() {
             $this->pool = null;
         });
 

src/Powered/Native/Server.php

Spacing +2 added lines, -2 removed lines

@@ -83,7 +83,7 @@ 
      */
     public function serve() : void
     {
-        swoole_event_add($this->listener, function ($server) {
+        swoole_event_add($this->listener, function($server) {
             $this->incoming($server);
         });
     }
@@ -134,7 +134,7 @@ 
     private function incoming($server) : void
     {
         $idx = $this->idx += 1;
-        swoole_event_add($this->fds[$idx] = stream_socket_accept($server), function () use ($idx) {
+        swoole_event_add($this->fds[$idx] = stream_socket_accept($server), function() use ($idx) {
             $this->receiving($idx);
         });
     }

src/Powered/Swoole/Client.php

Spacing +1 added lines, -1 removed lines

@@ -90,7 +90,7 @@
             $this->http->set($pxc);
         }
 
-        $this->http->on('connect', function () {
+        $this->http->on('connect', function() {
             $this->http->on('error', [$this, 'failure']);
             $this->http->on('close', [$this, 'closing']);
         });

src/Powered/Swoole/Chips/Throws.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
      */
     private function throwing(Request $request, SWHClient $c) : void
     {
-        $url = (string) $request->getUri();
+        $url = (string)$request->getUri();
 
         switch ($c->statusCode) {
             case -1:

src/Powered/Swoole/Chips/Http.php

Spacing +2 added lines, -2 removed lines

@@ -33,7 +33,7 @@ 
 
         // -- net sender
 
-        $executor = function ($fn) use ($http, $request) {
+        $executor = function($fn) use ($http, $request) {
             $uri = $this->getUriPath($request->getUri());
 
             $stream = $request->getBody();
@@ -55,7 +55,7 @@ 
 
         // -- net receiver
 
-        $receiver = function (SWHClient $c) use ($request) {
+        $receiver = function(SWHClient $c) use ($request) {
             $code = $c->statusCode;
             $headers = (array)$c->headers;
             $response = $c->body;

src/Powered/Swoole/Chips/Socket.php

Spacing +4 added lines, -4 removed lines

@@ -88,7 +88,7 @@ 
 
         // -- message event
 
-        $http->on('message', static function (SWHClient $c, SWSFrame $f) use ($framing, $socket) {
+        $http->on('message', static function(SWHClient $c, SWSFrame $f) use ($framing, $socket) {
             switch ($f->opcode) {
                 case WSOpcode::CLOSING:
                     $socket->sv(false);
@@ -99,20 +99,20 @@ 
             }
         });
 
-        $http->on('close', static function (SWHClient $c) use ($framing, $socket) {
+        $http->on('close', static function(SWHClient $c) use ($framing, $socket) {
             $socket->sv(false);
             $framing->message()->close();
         });
 
         // -- socket dial
 
-        $connector = function ($fn) use ($http, $request) {
+        $connector = function($fn) use ($http, $request) {
             $http->upgrade($this->getUriPath($request->getUri()), $fn);
         };
 
         // -- socket resp
 
-        $response = function (SWHClient $c) use ($request, $framing, $socket) {
+        $response = function(SWHClient $c) use ($request, $framing, $socket) {
             $code = $c->statusCode;
 
             if ($code === 101) {

src/Client/Options/Proxy.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
      */
     public function hasProxy() : bool
     {
-        return ! empty($this->proxy);
+        return !empty($this->proxy);
     }
 
     /**

src/Client/Persistent.php

Spacing +2 added lines, -2 removed lines

@@ -48,8 +48,8 @@
                 new Address($host, $port)
             );
 
-            $cli->keepalived(static function (Pool $pool) use ($pk) {
-                $pool->closed()->then(function () use ($pk) {
+            $cli->keepalived(static function(Pool $pool) use ($pk) {
+                $pool->closed()->then(function() use ($pk) {
                     unset(self::$keeps[$pk]);
                 });
             });