deployphp / deployer

deps/vendor/react/socket/src/SecureServer.php

Spacing +5 added lines, -5 removed lines

@@ -142,10 +142,10 @@ 
         $this->context = $context;
 
         $that = $this;
-        $this->tcp->on('connection', function ($connection) use ($that) {
+        $this->tcp->on('connection', function($connection) use ($that) {
             $that->handleConnection($connection);
         });
-        $this->tcp->on('error', function ($error) use ($that) {
+        $this->tcp->on('error', function($error) use ($that) {
             $that->emit('error', array($error));
         });
     }
@@ -157,7 +157,7 @@ 
             return null;
         }
 
-        return \str_replace('tcp://' , 'tls://', $address);
+        return \str_replace('tcp://', 'tls://', $address);
     }
 
     public function pause()
@@ -193,10 +193,10 @@ 
         $that = $this;
 
         $this->encryption->enable($connection)->then(
-            function ($conn) use ($that) {
+            function($conn) use ($that) {
                 $that->emit('connection', array($conn));
             },
-            function ($error) use ($that, $connection, $remote) {
+            function($error) use ($that, $connection, $remote) {
                 $error = new \RuntimeException(
                     'Connection from ' . $remote . ' failed during TLS handshake: ' . $error->getMessage(),
                     $error->getCode()

deps/vendor/react/socket/src/TcpServer.php

Spacing +2 added lines, -2 removed lines

@@ -137,7 +137,7 @@ 
         $this->loop = $loop ?: Loop::get();
 
         // a single port has been given => assume localhost
-        if ((string)(int)$uri === (string)$uri) {
+        if ((string) (int) $uri === (string) $uri) {
             $uri = '127.0.0.1:' . $uri;
         }
 
@@ -229,7 +229,7 @@ 
         }
 
         $that = $this;
-        $this->loop->addReadStream($this->master, function ($master) use ($that) {
+        $this->loop->addReadStream($this->master, function($master) use ($that) {
             try {
                 $newSocket = SocketServer::accept($master);
             } catch (\RuntimeException $e) {

deps/vendor/react/socket/src/SecureConnector.php

Spacing +5 added lines, -5 removed lines

@@ -55,7 +55,7 @@ 
         /** @var \React\Promise\PromiseInterface<ConnectionInterface> $promise */
         $promise = $this->connector->connect(
             \str_replace('tls://', '', $uri)
-        )->then(function (ConnectionInterface $connection) use ($context, $encryption, $uri, &$promise, &$connected) {
+        )->then(function(ConnectionInterface $connection) use ($context, $encryption, $uri, &$promise, &$connected) {
             // (unencrypted) TCP/IP connection succeeded
             $connected = true;
 
@@ -70,7 +70,7 @@ 
             }
 
             // try to enable encryption
-            return $promise = $encryption->enable($connection)->then(null, function ($error) use ($connection, $uri) {
+            return $promise = $encryption->enable($connection)->then(null, function($error) use ($connection, $uri) {
                 // establishing encryption failed => close invalid connection and return error
                 $connection->close();
 
@@ -79,7 +79,7 @@ 
                     $error->getCode()
                 );
             });
-        }, function (\Exception $e) use ($uri) {
+        }, function(\Exception $e) use ($uri) {
             if ($e instanceof \RuntimeException) {
                 $message = \preg_replace('/^Connection to [^ ]+/', '', $e->getMessage());
                 $e = new \RuntimeException(
@@ -113,10 +113,10 @@ 
         });
 
         return new \React\Promise\Promise(
-            function ($resolve, $reject) use ($promise) {
+            function($resolve, $reject) use ($promise) {
                 $promise->then($resolve, $reject);
             },
-            function ($_, $reject) use (&$promise, $uri, &$connected) {
+            function($_, $reject) use (&$promise, $uri, &$connected) {
                 if ($connected) {
                     $reject(new \RuntimeException(
                         'Connection to ' . $uri . ' cancelled during TLS handshake (ECONNABORTED)',

deps/vendor/react/socket/src/StreamEncryption.php

Spacing +4 added lines, -4 removed lines

@@ -66,7 +66,7 @@ 
         // TODO: add write() event to make sure we're not sending any excessive data
 
         // cancelling this leaves this stream in an inconsistent state…
-        $deferred = new Deferred(function () {
+        $deferred = new Deferred(function() {
             throw new \RuntimeException();
         });
 
@@ -81,7 +81,7 @@ 
         }
 
         $that = $this;
-        $toggleCrypto = function () use ($socket, $deferred, $toggle, $method, $that) {
+        $toggleCrypto = function() use ($socket, $deferred, $toggle, $method, $that) {
             $that->toggleCrypto($socket, $deferred, $toggle, $method);
         };
 
@@ -93,7 +93,7 @@ 
 
         $loop = $this->loop;
 
-        return $deferred->promise()->then(function () use ($stream, $socket, $loop, $toggle) {
+        return $deferred->promise()->then(function() use ($stream, $socket, $loop, $toggle) {
             $loop->removeReadStream($socket);
 
             $stream->encryptionEnabled = $toggle;
@@ -118,7 +118,7 @@ 
     public function toggleCrypto($socket, Deferred $deferred, $toggle, $method)
     {
         $error = null;
-        \set_error_handler(function ($_, $errstr) use (&$error) {
+        \set_error_handler(function($_, $errstr) use (&$error) {
             $error = \str_replace(array("\r", "\n"), ' ', $errstr);
 
             // remove useless function name from error message

deps/vendor/react/socket/src/TimeoutConnector.php

Spacing +5 added lines, -5 removed lines

@@ -34,15 +34,15 @@ 
 
         $loop = $this->loop;
         $time = $this->timeout;
-        return new Promise(function ($resolve, $reject) use ($loop, $time, $promise, $uri) {
+        return new Promise(function($resolve, $reject) use ($loop, $time, $promise, $uri) {
             $timer = null;
-            $promise = $promise->then(function ($v) use (&$timer, $loop, $resolve) {
+            $promise = $promise->then(function($v) use (&$timer, $loop, $resolve) {
                 if ($timer) {
                     $loop->cancelTimer($timer);
                 }
                 $timer = false;
                 $resolve($v);
-            }, function ($v) use (&$timer, $loop, $reject) {
+            }, function($v) use (&$timer, $loop, $reject) {
                 if ($timer) {
                     $loop->cancelTimer($timer);
                 }
@@ -56,7 +56,7 @@ 
             }
 
             // start timeout timer which will cancel the pending promise
-            $timer = $loop->addTimer($time, function () use ($time, &$promise, $reject, $uri) {
+            $timer = $loop->addTimer($time, function() use ($time, &$promise, $reject, $uri) {
                 $reject(new \RuntimeException(
                     'Connection to ' . $uri . ' timed out after ' . $time . ' seconds (ETIMEDOUT)',
                     \defined('SOCKET_ETIMEDOUT') ? \SOCKET_ETIMEDOUT : 110
@@ -68,7 +68,7 @@ 
                 $promise->cancel();
                 $promise = null;
             });
-        }, function () use (&$promise) {
+        }, function() use (&$promise) {
             // Cancelling this promise will cancel the pending connection, thus triggering the rejection logic above.
             // Avoid garbage references in call stack by passing pending promise by reference.
             assert(\method_exists($promise, 'cancel'));

deps/vendor/react/socket/src/TcpConnector.php

Spacing +4 added lines, -4 removed lines

@@ -106,8 +106,8 @@ 
 
         // wait for connection
         $loop = $this->loop;
-        return new Promise\Promise(function ($resolve, $reject) use ($loop, $stream, $uri) {
-            $loop->addWriteStream($stream, function ($stream) use ($loop, $resolve, $reject, $uri) {
+        return new Promise\Promise(function($resolve, $reject) use ($loop, $stream, $uri) {
+            $loop->addWriteStream($stream, function($stream) use ($loop, $resolve, $reject, $uri) {
                 $loop->removeWriteStream($stream);
 
                 // The following hack looks like the only way to
@@ -126,7 +126,7 @@ 
                         // This is only known to work on Linux, Mac and Windows are known to not support this.
                         $errno = 0;
                         $errstr = '';
-                        \set_error_handler(function ($_, $error) use (&$errno, &$errstr) {
+                        \set_error_handler(function($_, $error) use (&$errno, &$errstr) {
                             // Match errstr from PHP's warning message.
                             // fwrite(): send of 1 bytes failed with errno=111 Connection refused
                             \preg_match('/errno=(\d+) (.+)/', $error, $m);
@@ -153,7 +153,7 @@ 
                     $resolve(new Connection($stream, $loop));
                 }
             });
-        }, function () use ($loop, $stream, $uri) {
+        }, function() use ($loop, $stream, $uri) {
             $loop->removeWriteStream($stream);
             \fclose($stream);
 

deps/vendor/react/socket/src/SocketServer.php

Spacing +3 added lines, -3 removed lines

@@ -72,10 +72,10 @@ 
         $this->server = $server;
 
         $that = $this;
-        $server->on('connection', function (ConnectionInterface $conn) use ($that) {
+        $server->on('connection', function(ConnectionInterface $conn) use ($that) {
             $that->emit('connection', array($conn));
         });
-        $server->on('error', function (\Exception $error) use ($that) {
+        $server->on('error', function(\Exception $error) use ($that) {
             $that->emit('error', array($error));
         });
     }
@@ -112,7 +112,7 @@ 
     {
         $errno = 0;
         $errstr = '';
-        \set_error_handler(function ($_, $error) use (&$errno, &$errstr) {
+        \set_error_handler(function($_, $error) use (&$errno, &$errstr) {
             // Match errstr from PHP's warning message.
             // stream_socket_accept(): accept failed: Connection timed out
             $errstr = \preg_replace('#.*: #', '', $error);

deps/vendor/react/socket/src/LimitingServer.php

Spacing +1 added lines, -1 removed lines

@@ -164,7 +164,7 @@
 
         $this->connections[] = $connection;
         $that = $this;
-        $connection->on('close', function () use ($that, $connection) {
+        $connection->on('close', function() use ($that, $connection) {
             $that->handleDisconnection($connection);
         });
 

deps/vendor/react/http/src/Middleware/RequestBodyParserMiddleware.php

Spacing +1 added lines, -1 removed lines

@@ -39,7 +39,7 @@
         // parse string into array structure
         // ignore warnings due to excessive data structures (max_input_vars and max_input_nesting_level)
         $ret = array();
-        @\parse_str((string)$request->getBody(), $ret);
+        @\parse_str((string) $request->getBody(), $ret);
 
         return $request->withParsedBody($ret);
     }