deployphp / deployer

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

Spacing +13 added lines, -13 removed lines

@@ -69,7 +69,7 @@ 
     public function send(RequestInterface $request)
     {
         $state = new ClientRequestState();
-        $deferred = new Deferred(function () use ($state) {
+        $deferred = new Deferred(function() use ($state) {
             if ($state->pending !== null) {
                 $state->pending->cancel();
                 $state->pending = null;
@@ -77,11 +77,11 @@ 
         });
 
         // use timeout from options or default to PHP's default_socket_timeout (60)
-        $timeout = (float)($this->timeout !== null ? $this->timeout : ini_get("default_socket_timeout"));
+        $timeout = (float) ($this->timeout !== null ? $this->timeout : ini_get("default_socket_timeout"));
 
         $loop = $this->loop;
         $this->next($request, $deferred, $state)->then(
-            function (ResponseInterface $response) use ($state, $deferred, $loop, &$timeout) {
+            function(ResponseInterface $response) use ($state, $deferred, $loop, &$timeout) {
                 if ($state->timeout !== null) {
                     $loop->cancelTimer($state->timeout);
                     $state->timeout = null;
@@ -89,7 +89,7 @@ 
                 $timeout = -1;
                 $deferred->resolve($response);
             },
-            function ($e) use ($state, $deferred, $loop, &$timeout) {
+            function($e) use ($state, $deferred, $loop, &$timeout) {
                 if ($state->timeout !== null) {
                     $loop->cancelTimer($state->timeout);
                     $state->timeout = null;
@@ -106,7 +106,7 @@ 
         $body = $request->getBody();
         if ($body instanceof ReadableStreamInterface && $body->isReadable()) {
             $that = $this;
-            $body->on('close', function () use ($that, $deferred, $state, &$timeout) {
+            $body->on('close', function() use ($that, $deferred, $state, &$timeout) {
                 if ($timeout >= 0) {
                     $that->applyTimeout($deferred, $state, $timeout);
                 }
@@ -125,7 +125,7 @@ 
      */
     public function applyTimeout(Deferred $deferred, ClientRequestState $state, $timeout)
     {
-        $state->timeout = $this->loop->addTimer($timeout, function () use ($timeout, $deferred, $state) {
+        $state->timeout = $this->loop->addTimer($timeout, function() use ($timeout, $deferred, $state) {
             $deferred->reject(new \RuntimeException(
                 'Request timed out after ' . $timeout . ' seconds'
             ));
@@ -146,7 +146,7 @@ 
         $promise = $this->sender->send($request);
 
         if (!$this->streaming) {
-            $promise = $promise->then(function ($response) use ($deferred, $state, $that) {
+            $promise = $promise->then(function($response) use ($deferred, $state, $that) {
                 return $that->bufferResponse($response, $deferred, $state);
             });
         }
@@ -154,7 +154,7 @@ 
         $state->pending = $promise;
 
         return $promise->then(
-            function (ResponseInterface $response) use ($request, $that, $deferred, $state) {
+            function(ResponseInterface $response) use ($request, $that, $deferred, $state) {
                 return $that->onResponse($response, $request, $deferred, $state);
             }
         );
@@ -186,15 +186,15 @@ 
         $closer = null;
         $maximumSize = $this->maximumSize;
 
-        return $state->pending = new Promise(function ($resolve, $reject) use ($body, $maximumSize, $response, &$closer) {
+        return $state->pending = new Promise(function($resolve, $reject) use ($body, $maximumSize, $response, &$closer) {
             // resolve with current buffer when stream closes successfully
             $buffer = '';
-            $body->on('close', $closer = function () use (&$buffer, $response, $maximumSize, $resolve, $reject) {
+            $body->on('close', $closer = function() use (&$buffer, $response, $maximumSize, $resolve, $reject) {
                 $resolve($response->withBody(new BufferedBody($buffer)));
             });
 
             // buffer response body data in memory
-            $body->on('data', function ($data) use (&$buffer, $maximumSize, $body, $closer, $reject) {
+            $body->on('data', function($data) use (&$buffer, $maximumSize, $body, $closer, $reject) {
                 $buffer .= $data;
 
                 // close stream and reject promise if limit is exceeded
@@ -212,14 +212,14 @@ 
             });
 
             // reject buffering if body emits error
-            $body->on('error', function (\Exception $e) use ($reject) {
+            $body->on('error', function(\Exception $e) use ($reject) {
                 $reject(new \RuntimeException(
                     'Error while buffering response body: ' . $e->getMessage(),
                     $e->getCode(),
                     $e
                 ));
             });
-        }, function () use ($body, &$closer) {
+        }, function() use ($body, &$closer) {
             // cancelled buffering: remove close handler to avoid resolving, then close and reject
             assert($closer instanceof \Closure);
             $body->removeListener('close', $closer);

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

Spacing +11 added lines, -11 removed lines

@@ -110,7 +110,7 @@ 
         $this->parser = new RequestHeaderParser($this->clock);
 
         $that = $this;
-        $this->parser->on('headers', function (ServerRequestInterface $request, ConnectionInterface $conn) use ($that) {
+        $this->parser->on('headers', function(ServerRequestInterface $request, ConnectionInterface $conn) use ($that) {
             $that->handleRequest($conn, $request);
         });
 
@@ -157,12 +157,12 @@ 
         }
 
         // cancel pending promise once connection closes
-        $connectionOnCloseResponseCancelerHandler = function () {};
+        $connectionOnCloseResponseCancelerHandler = function() {};
         if ($response instanceof PromiseInterface && \method_exists($response, 'cancel')) {
-            $connectionOnCloseResponseCanceler = function () use ($response) {
+            $connectionOnCloseResponseCanceler = function() use ($response) {
                 $response->cancel();
             };
-            $connectionOnCloseResponseCancelerHandler = function () use ($connectionOnCloseResponseCanceler, $conn) {
+            $connectionOnCloseResponseCancelerHandler = function() use ($connectionOnCloseResponseCanceler, $conn) {
                 if ($connectionOnCloseResponseCanceler !== null) {
                     $conn->removeListener('close', $connectionOnCloseResponseCanceler);
                 }
@@ -182,7 +182,7 @@ 
 
         $that = $this;
         $response->then(
-            function ($response) use ($that, $conn, $request) {
+            function($response) use ($that, $conn, $request) {
                 if (!$response instanceof ResponseInterface) {
                     $message = 'The response callback is expected to resolve with an object implementing Psr\Http\Message\ResponseInterface, but resolved with "%s" instead.';
                     $message = \sprintf($message, \is_object($response) ? \get_class($response) : \gettype($response));
@@ -193,7 +193,7 @@ 
                 }
                 $that->handleResponse($conn, $request, $response);
             },
-            function ($error) use ($that, $conn, $request) {
+            function($error) use ($that, $conn, $request) {
                 $message = 'The response callback is expected to resolve with an object implementing Psr\Http\Message\ResponseInterface, but rejected with "%s" instead.';
                 $message = \sprintf($message, \is_object($error) ? \get_class($error) : \gettype($error));
 
@@ -255,7 +255,7 @@ 
         // assign default "Server" header automatically
         if (!$response->hasHeader('Server')) {
             $response = $response->withHeader('Server', 'ReactPHP/1');
-        } elseif ($response->getHeaderLine('Server') === ''){
+        } elseif ($response->getHeaderLine('Server') === '') {
             $response = $response->withoutHeader('Server');
         }
 
@@ -263,7 +263,7 @@ 
         if (!$response->hasHeader('Date')) {
             // IMF-fixdate  = day-name "," SP date1 SP time-of-day SP GMT
             $response = $response->withHeader('Date', gmdate('D, d M Y H:i:s', (int) $this->clock->now()) . ' GMT');
-        } elseif ($response->getHeaderLine('Date') === ''){
+        } elseif ($response->getHeaderLine('Date') === '') {
             $response = $response->withoutHeader('Date');
         }
 
@@ -278,7 +278,7 @@ 
             // 304 Not Modified: preserve explicit Content-Length and preserve missing header if body is empty
         } elseif ($body->getSize() !== null) {
             // assign Content-Length header when using a "normal" buffered body string
-            $response = $response->withHeader('Content-Length', (string)$body->getSize());
+            $response = $response->withHeader('Content-Length', (string) $body->getSize());
         } elseif (!$response->hasHeader('Content-Length') && $version === '1.1') {
             // assign chunked transfer-encoding if no 'content-length' is given for HTTP/1.1 responses
             $chunked = true;
@@ -319,7 +319,7 @@ 
         if (($code === Response::STATUS_SWITCHING_PROTOCOLS || ($method === 'CONNECT' && $code >= 200 && $code < 300)) && $body instanceof HttpBodyStream && $body->input instanceof WritableStreamInterface) {
             if ($request->getBody()->isReadable()) {
                 // request is still streaming => wait for request close before forwarding following data from connection
-                $request->getBody()->on('close', function () use ($connection, $body) {
+                $request->getBody()->on('close', function() use ($connection, $body) {
                     if ($body->input->isWritable()) {
                         $connection->pipe($body->input);
                         $connection->resume();
@@ -394,7 +394,7 @@ 
         if ($persist) {
             $body->pipe($connection, array('end' => false));
             $parser = $this->parser;
-            $body->on('end', function () use ($connection, $parser, $body) {
+            $body->on('end', function() use ($connection, $parser, $body) {
                 $connection->removeListener('close', array($body, 'close'));
                 $parser->handle($connection);
             });

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

Spacing +1 added lines, -1 removed lines

@@ -74,7 +74,7 @@
     {
         if (($this->transferredLength + \strlen($data)) > $this->maxLength) {
             // Only emit data until the value of 'Content-Length' is reached, the rest will be ignored
-            $data = (string)\substr($data, 0, $this->maxLength - $this->transferredLength);
+            $data = (string) \substr($data, 0, $this->maxLength - $this->transferredLength);
         }
 
         if ($data !== '') {

deps/vendor/react/http/src/HttpServer.php

Spacing +2 added lines, -2 removed lines

@@ -251,14 +251,14 @@
          * Filter out any configuration middleware, no need to run requests through something that isn't
          * doing anything with the request.
          */
-        $middleware = \array_filter($middleware, function ($handler) {
+        $middleware = \array_filter($middleware, function($handler) {
             return !($handler instanceof StreamingRequestMiddleware);
         });
 
         $this->streamingServer = new StreamingServer($loop, new MiddlewareRunner($middleware));
 
         $that = $this;
-        $this->streamingServer->on('error', function ($error) use ($that) {
+        $this->streamingServer->on('error', function($error) use ($that) {
             $that->emit('error', array($error));
         });
     }

deps/vendor/react/http/src/Browser.php

Spacing +1 added lines, -1 removed lines

@@ -235,7 +235,7 @@
      */
     public function patch($url, array $headers = array(), $body = '')
     {
-        return $this->requestMayBeStreaming('PATCH', $url , $headers, $body);
+        return $this->requestMayBeStreaming('PATCH', $url, $headers, $body);
     }
 
     /**

deps/vendor/react/event-loop/src/ExtEventLoop.php

Spacing +4 added lines, -4 removed lines

@@ -240,7 +240,7 @@ 
     private function createTimerCallback()
     {
         $timers = $this->timerEvents;
-        $this->timerCallback = function ($_, $__, $timer) use ($timers) {
+        $this->timerCallback = function($_, $__, $timer) use ($timers) {
             \call_user_func($timer->getCallback(), $timer);
 
             if (!$timer->isPeriodic() && $timers->contains($timer)) {
@@ -258,9 +258,9 @@ 
      */
     private function createStreamCallback()
     {
-        $read =& $this->readListeners;
-        $write =& $this->writeListeners;
-        $this->streamCallback = function ($stream, $flags) use (&$read, &$write) {
+        $read = & $this->readListeners;
+        $write = & $this->writeListeners;
+        $this->streamCallback = function($stream, $flags) use (&$read, &$write) {
             $key = (int) $stream;
 
             if (Event::READ === (Event::READ & $flags) && isset($read[$key])) {

deps/vendor/react/event-loop/src/Loop.php

Spacing +3 added lines, -3 removed lines

@@ -39,12 +39,12 @@
         // This is tested using child processes, so coverage is actually 100%, see BinTest.
         // @codeCoverageIgnoreStart
         $hasRun = false;
-        $loop->futureTick(function () use (&$hasRun) {
+        $loop->futureTick(function() use (&$hasRun) {
             $hasRun = true;
         });
 
-        $stopped =& self::$stopped;
-        register_shutdown_function(function () use ($loop, &$hasRun, &$stopped) {
+        $stopped = & self::$stopped;
+        register_shutdown_function(function() use ($loop, &$hasRun, &$stopped) {
             // Don't run if we're coming from a fatal error (uncaught exception).
             $error = error_get_last();
             if ((isset($error['type']) ? $error['type'] : 0) & (E_ERROR | E_CORE_ERROR | E_COMPILE_ERROR | E_USER_ERROR | E_RECOVERABLE_ERROR)) {

deps/vendor/react/event-loop/src/ExtUvLoop.php

Spacing +5 added lines, -5 removed lines

@@ -116,7 +116,7 @@ 
 
         $that = $this;
         $timers = $this->timers;
-        $callback = function () use ($timer, $timers, $that) {
+        $callback = function() use ($timer, $timers, $that) {
             \call_user_func($timer->getCallback(), $timer);
 
             if ($timers->contains($timer)) {
@@ -143,7 +143,7 @@ 
     {
         $timer = new Timer($interval, $callback, true);
 
-        $callback = function () use ($timer) {
+        $callback = function() use ($timer) {
             \call_user_func($timer->getCallback(), $timer);
         };
 
@@ -186,7 +186,7 @@ 
         if (!isset($this->signalEvents[$signal])) {
             $signals = $this->signals;
             $this->signalEvents[$signal] = \uv_signal_init($this->uv);
-            \uv_signal_start($this->signalEvents[$signal], function () use ($signals, $signal) {
+            \uv_signal_start($this->signalEvents[$signal], function() use ($signals, $signal) {
                 $signals->call($signal);
             }, $signal);
         }
@@ -244,7 +244,7 @@ 
     private function addStream($stream)
     {
         if (!isset($this->streamEvents[(int) $stream])) {
-            $this->streamEvents[(int)$stream] = \uv_poll_init_socket($this->uv, $stream);
+            $this->streamEvents[(int) $stream] = \uv_poll_init_socket($this->uv, $stream);
         }
 
         if ($this->streamEvents[(int) $stream] !== false) {
@@ -294,7 +294,7 @@ 
      */
     private function createStreamListener()
     {
-        $callback = function ($event, $status, $events, $stream) {
+        $callback = function($event, $status, $events, $stream) {
             // libuv automatically stops polling on error, re-enable polling to match other loop implementations
             if ($status !== 0) {
                 $this->pollStream($stream);

deps/vendor/react/event-loop/src/ExtEvLoop.php

Spacing +7 added lines, -7 removed lines

@@ -73,7 +73,7 @@ 
 
     public function addReadStream($stream, $listener)
     {
-        $key = (int)$stream;
+        $key = (int) $stream;
 
         if (isset($this->readStreams[$key])) {
             return;
@@ -92,14 +92,14 @@ 
      */
     private function getStreamListenerClosure($stream, $listener)
     {
-        return function () use ($stream, $listener) {
+        return function() use ($stream, $listener) {
             \call_user_func($listener, $stream);
         };
     }
 
     public function addWriteStream($stream, $listener)
     {
-        $key = (int)$stream;
+        $key = (int) $stream;
 
         if (isset($this->writeStreams[$key])) {
             return;
@@ -112,7 +112,7 @@ 
 
     public function removeReadStream($stream)
     {
-        $key = (int)$stream;
+        $key = (int) $stream;
 
         if (!isset($this->readStreams[$key])) {
             return;
@@ -124,7 +124,7 @@ 
 
     public function removeWriteStream($stream)
     {
-        $key = (int)$stream;
+        $key = (int) $stream;
 
         if (!isset($this->writeStreams[$key])) {
             return;
@@ -140,7 +140,7 @@ 
 
         $that = $this;
         $timers = $this->timers;
-        $callback = function () use ($timer, $timers, $that) {
+        $callback = function() use ($timer, $timers, $that) {
             \call_user_func($timer->getCallback(), $timer);
 
             if ($timers->contains($timer)) {
@@ -158,7 +158,7 @@ 
     {
         $timer = new Timer($interval, $callback, true);
 
-        $callback = function () use ($timer) {
+        $callback = function() use ($timer) {
             \call_user_func($timer->getCallback(), $timer);
         };