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/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/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);
     }

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

Spacing +5 added lines, -5 removed lines

@@ -130,12 +130,12 @@ 
         }
 
         // get next queue position
-        $queue =& $this->queue;
+        $queue = & $this->queue;
         $queue[] = null;
         \end($queue);
         $id = \key($queue);
 
-        $deferred = new Deferred(function ($_, $reject) use (&$queue, $id) {
+        $deferred = new Deferred(function($_, $reject) use (&$queue, $id) {
             // queued promise cancelled before its next handler is invoked
             // remove from queue and reject explicitly
             unset($queue[$id]);
@@ -147,7 +147,7 @@ 
 
         $pending = &$this->pending;
         $that = $this;
-        return $deferred->promise()->then(function () use ($request, $next, $body, &$pending, $that) {
+        return $deferred->promise()->then(function() use ($request, $next, $body, &$pending, $that) {
             // invoke next request handler
             ++$pending;
 
@@ -182,11 +182,11 @@ 
     {
         $that = $this;
 
-        return $promise->then(function ($response) use ($that) {
+        return $promise->then(function($response) use ($that) {
             $that->processQueue();
 
             return $response;
-        }, function ($error) use ($that) {
+        }, function($error) use ($that) {
             $that->processQueue();
 
             return Promise\reject($error);

deps/vendor/react/http/src/Io/ChunkedDecoder.php

Spacing +7 added lines, -7 removed lines

@@ -102,12 +102,12 @@ 
                 if ($positionCrlf === false) {
                     // Header shouldn't be bigger than 1024 bytes
                     if (isset($this->buffer[static::MAX_CHUNK_HEADER_SIZE])) {
-                        $this->handleError(new Exception('Chunk header size inclusive extension bigger than' . static::MAX_CHUNK_HEADER_SIZE. ' bytes'));
+                        $this->handleError(new Exception('Chunk header size inclusive extension bigger than' . static::MAX_CHUNK_HEADER_SIZE . ' bytes'));
                     }
                     return;
                 }
 
-                $header = \strtolower((string)\substr($this->buffer, 0, $positionCrlf));
+                $header = \strtolower((string) \substr($this->buffer, 0, $positionCrlf));
                 $hexValue = $header;
 
                 if (\strpos($header, ';') !== false) {
@@ -128,19 +128,19 @@ 
                     return;
                 }
 
-                $this->buffer = (string)\substr($this->buffer, $positionCrlf + 2);
+                $this->buffer = (string) \substr($this->buffer, $positionCrlf + 2);
                 $this->headerCompleted = true;
                 if ($this->buffer === '') {
                     return;
                 }
             }
 
-            $chunk = (string)\substr($this->buffer, 0, $this->chunkSize - $this->transferredSize);
+            $chunk = (string) \substr($this->buffer, 0, $this->chunkSize - $this->transferredSize);
 
             if ($chunk !== '') {
                 $this->transferredSize += \strlen($chunk);
                 $this->emit('data', array($chunk));
-                $this->buffer = (string)\substr($this->buffer, \strlen($chunk));
+                $this->buffer = (string) \substr($this->buffer, \strlen($chunk));
             }
 
             $positionCrlf = \strpos($this->buffer, static::CRLF);
@@ -154,10 +154,10 @@ 
                 $this->chunkSize = 0;
                 $this->headerCompleted = false;
                 $this->transferredSize = 0;
-                $this->buffer = (string)\substr($this->buffer, 2);
+                $this->buffer = (string) \substr($this->buffer, 2);
             } elseif ($this->chunkSize === 0) {
                 // end chunk received, skip all trailer data
-                $this->buffer = (string)\substr($this->buffer, $positionCrlf);
+                $this->buffer = (string) \substr($this->buffer, $positionCrlf);
             }
 
             if ($positionCrlf !== 0 && $this->chunkSize !== 0 && $this->chunkSize === $this->transferredSize && \strlen($this->buffer) > 2) {

deps/vendor/react/http/src/Io/UploadedFile.php

Indentation +1 added lines, -1 removed lines

@@ -93,7 +93,7 @@
      */
     public function moveTo($targetPath)
     {
-       throw new RuntimeException('Not implemented');
+        throw new RuntimeException('Not implemented');
     }
 
     /**

deps/vendor/react/http/src/Io/MiddlewareRunner.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
         }
 
         $that = $this;
-        $next = function (ServerRequestInterface $request) use ($that, $position) {
+        $next = function(ServerRequestInterface $request) use ($that, $position) {
             return $that->call($request, $position + 1);
         };