deployphp / deployer

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/Message/Uri.php

Spacing +2 added lines, -2 removed lines

@@ -283,7 +283,7 @@ 
     {
         return \preg_replace_callback(
             '/(?:[^a-z0-9_\-\.~!\$&\'\(\)\*\+,;=' . ($component === \PHP_URL_PATH ? ':@\/' : ($component === \PHP_URL_QUERY || $component === \PHP_URL_FRAGMENT ? ':@\/\?' : '')) . '%]++|%(?![a-f0-9]{2}))/i',
-            function (array $match) {
+            function(array $match) {
                 return \rawurlencode($match[0]);
             },
             $part
@@ -310,7 +310,7 @@ 
         if ($rel->getAuthority() !== '') {
             $reset = true;
             $userInfo = \explode(':', $rel->getUserInfo(), 2);
-            $new = $base->withUserInfo($userInfo[0], isset($userInfo[1]) ? $userInfo[1]: null)->withHost($rel->getHost())->withPort($rel->getPort());
+            $new = $base->withUserInfo($userInfo[0], isset($userInfo[1]) ? $userInfo[1] : null)->withHost($rel->getHost())->withPort($rel->getPort());
         }
 
         if ($reset && $rel->getPath() === '') {

deps/vendor/react/http/src/Message/ServerRequest.php

Spacing +1 added lines, -1 removed lines

@@ -320,7 +320,7 @@
         } elseif ($request->hasHeader('Content-Length')) {
             $string = $request->getHeaderLine('Content-Length');
 
-            if ((string)(int)$string !== $string) {
+            if ((string) (int) $string !== $string) {
                 // Content-Length value is not an integer or not a single integer
                 throw new \InvalidArgumentException('The value of `Content-Length` is not valid', Response::STATUS_BAD_REQUEST);
             }

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/ClientRequestStream.php

Spacing +3 added lines, -3 removed lines

@@ -82,7 +82,7 @@ 
 
         $promise = $this->connectionManager->connect($this->request->getUri());
         $promise->then(
-            function (ConnectionInterface $connection) use ($headers, &$connectionRef, &$stateRef, &$pendingWrites, $that) {
+            function(ConnectionInterface $connection) use ($headers, &$connectionRef, &$stateRef, &$pendingWrites, $that) {
                 $connectionRef = $connection;
                 assert($connectionRef instanceof ConnectionInterface);
 
@@ -194,7 +194,7 @@ 
             $connectionManager = $this->connectionManager;
             $successfulEndReceived = false;
             $input = $body = new CloseProtectionStream($connection);
-            $input->on('close', function () use ($connection, $that, $connectionManager, $request, $response, &$successfulEndReceived) {
+            $input->on('close', function() use ($connection, $that, $connectionManager, $request, $response, &$successfulEndReceived) {
                 // only reuse connection after successful response and both request and response allow keep alive
                 if ($successfulEndReceived && $connection->isReadable() && $that->hasMessageKeepAliveEnabled($response) && $that->hasMessageKeepAliveEnabled($request)) {
                     $connectionManager->keepAlive($request->getUri(), $connection);
@@ -216,7 +216,7 @@ 
                 $length = (int) $response->getHeaderLine('Content-Length');
             }
             $response = $response->withBody($body = new ReadableBodyStream($body, $length));
-            $body->on('end', function () use (&$successfulEndReceived) {
+            $body->on('end', function() use (&$successfulEndReceived) {
                 $successfulEndReceived = true;
             });
 

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

Spacing +5 added lines, -5 removed lines

@@ -40,7 +40,7 @@ 
         $buffer = '';
         $maxSize = $this->maxSize;
         $that = $this;
-        $conn->on('data', $fn = function ($data) use (&$buffer, &$fn, $conn, $maxSize, $that) {
+        $conn->on('data', $fn = function($data) use (&$buffer, &$fn, $conn, $maxSize, $that) {
             // append chunk of data to buffer and look for end of request headers
             $buffer .= $data;
             $endOfHeader = \strpos($buffer, "\r\n\r\n");
@@ -68,7 +68,7 @@ 
 
             try {
                 $request = $that->parseRequest(
-                    (string)\substr($buffer, 0, $endOfHeader + 2),
+                    (string) \substr($buffer, 0, $endOfHeader + 2),
                     $conn
                 );
             } catch (Exception $exception) {
@@ -84,7 +84,7 @@ 
             if ($request->hasHeader('Transfer-Encoding')) {
                 $contentLength = null;
             } elseif ($request->hasHeader('Content-Length')) {
-                $contentLength = (int)$request->getHeaderLine('Content-Length');
+                $contentLength = (int) $request->getHeaderLine('Content-Length');
             }
 
             if ($contentLength === 0) {
@@ -162,8 +162,8 @@ 
 
             // remember server params for all requests from this connection, reset on connection close
             $this->connectionParams[$cid] = $serverParams;
-            $params =& $this->connectionParams;
-            $connection->on('close', function () use (&$params, $cid) {
+            $params = & $this->connectionParams;
+            $connection->on('close', function() use (&$params, $cid) {
                 assert(\is_array($params));
                 unset($params[$cid]);
             });

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/Clock.php

Spacing +2 added lines, -2 removed lines

@@ -42,8 +42,8 @@
             $this->now = \microtime(true);
 
             // remember clock for current loop tick only and update on next tick
-            $now =& $this->now;
-            $this->loop->futureTick(function () use (&$now) {
+            $now = & $this->now;
+            $this->loop->futureTick(function() use (&$now) {
                 assert($now !== null);
                 $now = null;
             });

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

Spacing +1 added lines, -1 removed lines

@@ -101,7 +101,7 @@
         $this->idleConnections[] = $connection;
 
         $that = $this;
-        $cleanUp = function () use ($connection, $that) {
+        $cleanUp = function() use ($connection, $that) {
             // call public method to support legacy PHP 5.3
             $that->cleanUpConnection($connection);
         };