deployphp / deployer

deps/vendor/react/dns/src/Query/RetryExecutor.php

Spacing +3 added lines, -3 removed lines

@@ -23,19 +23,19 @@
 
     public function tryQuery(Query $query, $retries)
     {
-        $deferred = new Deferred(function () use (&$promise) {
+        $deferred = new Deferred(function() use (&$promise) {
             if ($promise instanceof PromiseInterface && \method_exists($promise, 'cancel')) {
                 $promise->cancel();
             }
         });
 
-        $success = function ($value) use ($deferred, &$errorback) {
+        $success = function($value) use ($deferred, &$errorback) {
             $errorback = null;
             $deferred->resolve($value);
         };
 
         $executor = $this->executor;
-        $errorback = function ($e) use ($deferred, &$promise, $query, $success, &$errorback, &$retries, $executor) {
+        $errorback = function($e) use ($deferred, &$promise, $query, $success, &$errorback, &$retries, $executor) {
             if (!$e instanceof TimeoutException) {
                 $errorback = null;
                 $deferred->reject($e);

deps/vendor/react/dns/src/Query/TimeoutExecutor.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, $query) {
+        return new Promise(function($resolve, $reject) use ($loop, $time, $promise, $query) {
             $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, $query) {
+            $timer = $loop->addTimer($time, function() use ($time, &$promise, $reject, $query) {
                 $reject(new TimeoutException(
                     'DNS query for ' . $query->describe() . ' timed out'
                 ));
@@ -67,7 +67,7 @@ 
                 $promise->cancel();
                 $promise = null;
             });
-        }, function () use (&$promise) {
+        }, function() use (&$promise) {
             // Cancelling this promise will cancel the pending query, 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/dns/src/Query/TcpTransportExecutor.php

Spacing +6 added lines, -6 removed lines

@@ -180,7 +180,7 @@ 
             $socket = @\stream_socket_client($this->nameserver, $errno, $errstr, 0, \STREAM_CLIENT_CONNECT | \STREAM_CLIENT_ASYNC_CONNECT);
             if ($socket === false) {
                 return \React\Promise\reject(new \RuntimeException(
-                    'DNS query for ' . $query->describe() . ' failed: Unable to connect to DNS server ' . $this->nameserver . ' ('  . $errstr . ')',
+                    'DNS query for ' . $query->describe() . ' failed: Unable to connect to DNS server ' . $this->nameserver . ' (' . $errstr . ')',
                     $errno
                 ));
             }
@@ -205,9 +205,9 @@ 
             $this->loop->addWriteStream($this->socket, array($this, 'handleWritable'));
         }
 
-        $names =& $this->names;
+        $names = & $this->names;
         $that = $this;
-        $deferred = new Deferred(function () use ($that, &$names, $request) {
+        $deferred = new Deferred(function() use ($that, &$names, $request) {
             // remove from list of pending names, but remember pending query
             $name = $names[$request->id];
             unset($names[$request->id]);
@@ -252,7 +252,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.
             // fwrite(): Send of 327712 bytes failed with errno=32 Broken pipe
             \preg_match('/errno=(\d+) (.+)/', $error, $m);
@@ -306,7 +306,7 @@ 
             }
 
             $data = \substr($this->readBuffer, 2, $length);
-            $this->readBuffer = (string)substr($this->readBuffer, $length + 2);
+            $this->readBuffer = (string) substr($this->readBuffer, $length + 2);
 
             try {
                 $response = $this->parser->parseMessage($data);
@@ -374,7 +374,7 @@ 
     {
         if ($this->idleTimer === null && !$this->names) {
             $that = $this;
-            $this->idleTimer = $this->loop->addTimer($this->idlePeriod, function () use ($that) {
+            $this->idleTimer = $this->loop->addTimer($this->idlePeriod, function() use ($that) {
                 $that->closeError('Idle timeout');
             });
         }

deps/vendor/react/dns/src/Query/UdpTransportExecutor.php

Spacing +5 added lines, -5 removed lines

@@ -138,7 +138,7 @@ 
         $socket = @\stream_socket_client($this->nameserver, $errno, $errstr, 0);
         if ($socket === false) {
             return \React\Promise\reject(new \RuntimeException(
-                'DNS query for ' . $query->describe() . ' failed: Unable to connect to DNS server ' . $this->nameserver . ' ('  . $errstr . ')',
+                'DNS query for ' . $query->describe() . ' failed: Unable to connect to DNS server ' . $this->nameserver . ' (' . $errstr . ')',
                 $errno
             ));
         }
@@ -146,7 +146,7 @@ 
         // set socket to non-blocking and immediately try to send (fill write buffer)
         \stream_set_blocking($socket, false);
 
-        \set_error_handler(function ($_, $error) use (&$errno, &$errstr) {
+        \set_error_handler(function($_, $error) use (&$errno, &$errstr) {
             // Write may potentially fail, but most common errors are already caught by connection check above.
             // Among others, macOS is known to report here when trying to send to broadcast address.
             // This can also be reproduced by writing data exceeding `stream_set_chunk_size()` to a server refusing UDP data.
@@ -162,13 +162,13 @@ 
 
         if ($written !== \strlen($queryData)) {
             return \React\Promise\reject(new \RuntimeException(
-                'DNS query for ' . $query->describe() . ' failed: Unable to send query to DNS server ' . $this->nameserver . ' ('  . $errstr . ')',
+                'DNS query for ' . $query->describe() . ' failed: Unable to send query to DNS server ' . $this->nameserver . ' (' . $errstr . ')',
                 $errno
             ));
         }
 
         $loop = $this->loop;
-        $deferred = new Deferred(function () use ($loop, $socket, $query) {
+        $deferred = new Deferred(function() use ($loop, $socket, $query) {
             // cancellation should remove socket from loop and close socket
             $loop->removeReadStream($socket);
             \fclose($socket);
@@ -179,7 +179,7 @@ 
         $max = $this->maxPacketSize;
         $parser = $this->parser;
         $nameserver = $this->nameserver;
-        $loop->addReadStream($socket, function ($socket) use ($loop, $deferred, $query, $parser, $request, $max, $nameserver) {
+        $loop->addReadStream($socket, function($socket) use ($loop, $deferred, $query, $parser, $request, $max, $nameserver) {
             // try to read a single data packet from the DNS server
             // ignoring any errors, this is uses UDP packets and not a stream of data
             $data = @\fread($socket, $max);

deps/vendor/react/promise/src/Internal/FulfilledPromise.php

Spacing +3 added lines, -3 removed lines

@@ -51,15 +51,15 @@
         }
     }
 
-    public function catch(callable $onRejected): PromiseInterface
+    public function catch (callable $onRejected): PromiseInterface
     {
         return $this;
     }
 
     public function finally(callable $onFulfilledOrRejected): PromiseInterface
     {
-        return $this->then(function ($value) use ($onFulfilledOrRejected): PromiseInterface {
-            return resolve($onFulfilledOrRejected())->then(function () use ($value) {
+        return $this->then(function($value) use ($onFulfilledOrRejected): PromiseInterface {
+            return resolve($onFulfilledOrRejected())->then(function() use ($value) {
                 return $value;
             });
         });

deps/vendor/react/promise/src/Internal/RejectedPromise.php

Spacing +3 added lines, -3 removed lines

@@ -82,7 +82,7 @@ 
      * @param callable(TThrowable): (PromiseInterface<TRejected>|TRejected) $onRejected
      * @return PromiseInterface<TRejected>
      */
-    public function catch(callable $onRejected): PromiseInterface
+    public function catch (callable $onRejected): PromiseInterface
     {
         if (!_checkTypehint($onRejected, $this->reason)) {
             return $this;
@@ -96,8 +96,8 @@ 
 
     public function finally(callable $onFulfilledOrRejected): PromiseInterface
     {
-        return $this->then(null, function (\Throwable $reason) use ($onFulfilledOrRejected): PromiseInterface {
-            return resolve($onFulfilledOrRejected())->then(function () use ($reason): PromiseInterface {
+        return $this->then(null, function(\Throwable $reason) use ($onFulfilledOrRejected): PromiseInterface {
+            return resolve($onFulfilledOrRejected())->then(function() use ($reason): PromiseInterface {
                 return new RejectedPromise($reason);
             });
         });

deps/vendor/react/promise/src/PromiseInterface.php

Spacing +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
      * @param callable(TThrowable): (PromiseInterface<TRejected>|TRejected) $onRejected
      * @return PromiseInterface<T|TRejected>
      */
-    public function catch(callable $onRejected): PromiseInterface;
+    public function catch (callable $onRejected): PromiseInterface;
 
     /**
      * Allows you to execute "cleanup" type tasks in a promise chain.

deps/vendor/react/promise/src/Deferred.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
      */
     public function __construct(?callable $canceller = null)
     {
-        $this->promise = new Promise(function ($resolve, $reject): void {
+        $this->promise = new Promise(function($resolve, $reject): void {
             $this->resolveCallback = $resolve;
             $this->rejectCallback  = $reject;
         }, $canceller);

deps/vendor/react/promise/src/functions.php

Spacing +9 added lines, -9 removed lines

@@ -36,7 +36,7 @@ 
         }
 
         /** @var Promise<T> */
-        return new Promise(function (callable $resolve, callable $reject) use ($promiseOrValue): void {
+        return new Promise(function(callable $resolve, callable $reject) use ($promiseOrValue): void {
             $promiseOrValue->then($resolve, $reject);
         }, $canceller);
     }
@@ -79,7 +79,7 @@ 
     $cancellationQueue = new Internal\CancellationQueue();
 
     /** @var Promise<array<T>> */
-    return new Promise(function (callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void {
+    return new Promise(function(callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void {
         $toResolve = 0;
         /** @var bool */
         $continue  = true;
@@ -91,14 +91,14 @@ 
             ++$toResolve;
 
             resolve($promiseOrValue)->then(
-                function ($value) use ($i, &$values, &$toResolve, &$continue, $resolve): void {
+                function($value) use ($i, &$values, &$toResolve, &$continue, $resolve): void {
                     $values[$i] = $value;
 
                     if (0 === --$toResolve && !$continue) {
                         $resolve($values);
                     }
                 },
-                function (\Throwable $reason) use (&$continue, $reject): void {
+                function(\Throwable $reason) use (&$continue, $reject): void {
                     $continue = false;
                     $reject($reason);
                 }
@@ -132,13 +132,13 @@ 
     $cancellationQueue = new Internal\CancellationQueue();
 
     /** @var Promise<T> */
-    return new Promise(function (callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void {
+    return new Promise(function(callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void {
         $continue = true;
 
         foreach ($promisesOrValues as $promiseOrValue) {
             $cancellationQueue->enqueue($promiseOrValue);
 
-            resolve($promiseOrValue)->then($resolve, $reject)->finally(function () use (&$continue): void {
+            resolve($promiseOrValue)->then($resolve, $reject)->finally(function() use (&$continue): void {
                 $continue = false;
             });
 
@@ -169,7 +169,7 @@ 
     $cancellationQueue = new Internal\CancellationQueue();
 
     /** @var Promise<T> */
-    return new Promise(function (callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void {
+    return new Promise(function(callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void {
         $toReject = 0;
         $continue = true;
         $reasons  = [];
@@ -179,11 +179,11 @@ 
             ++$toReject;
 
             resolve($promiseOrValue)->then(
-                function ($value) use ($resolve, &$continue): void {
+                function($value) use ($resolve, &$continue): void {
                     $continue = false;
                     $resolve($value);
                 },
-                function (\Throwable $reason) use ($i, &$reasons, &$toReject, $reject, &$continue): void {
+                function(\Throwable $reason) use ($i, &$reasons, &$toReject, $reject, &$continue): void {
                     $reasons[$i] = $reason;
 
                     if (0 === --$toReject && !$continue) {