deployphp / deployer

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

Spacing +15 added lines, -15 removed lines

@@ -45,7 +45,7 @@ 
 
         return new static(
             $this->resolver($onFulfilled, $onRejected, $onProgress),
-            static function () use (&$parent) {
+            static function() use (&$parent) {
                 if (++$parent->cancelRequests >= $parent->requiredCancelRequests) {
                     $parent->cancel();
                 }
@@ -61,7 +61,7 @@ 
             return $this->result->done($onFulfilled, $onRejected, $onProgress);
         }
 
-        $this->handlers[] = static function (ExtendedPromiseInterface $promise) use ($onFulfilled, $onRejected) {
+        $this->handlers[] = static function(ExtendedPromiseInterface $promise) use ($onFulfilled, $onRejected) {
             $promise
                 ->done($onFulfilled, $onRejected);
         };
@@ -73,7 +73,7 @@ 
 
     public function otherwise(callable $onRejected)
     {
-        return $this->then(null, static function ($reason) use ($onRejected) {
+        return $this->then(null, static function($reason) use ($onRejected) {
             if (!_checkTypehint($onRejected, $reason)) {
                 return new RejectedPromise($reason);
             }
@@ -84,12 +84,12 @@ 
 
     public function always(callable $onFulfilledOrRejected)
     {
-        return $this->then(static function ($value) use ($onFulfilledOrRejected) {
-            return resolve($onFulfilledOrRejected())->then(function () use ($value) {
+        return $this->then(static function($value) use ($onFulfilledOrRejected) {
+            return resolve($onFulfilledOrRejected())->then(function() use ($value) {
                 return $value;
             });
-        }, static function ($reason) use ($onFulfilledOrRejected) {
-            return resolve($onFulfilledOrRejected())->then(function () use ($reason) {
+        }, static function($reason) use ($onFulfilledOrRejected) {
+            return resolve($onFulfilledOrRejected())->then(function() use ($reason) {
                 return new RejectedPromise($reason);
             });
         });
@@ -114,9 +114,9 @@ 
 
     private function resolver(callable $onFulfilled = null, callable $onRejected = null, callable $onProgress = null)
     {
-        return function ($resolve, $reject, $notify) use ($onFulfilled, $onRejected, $onProgress) {
+        return function($resolve, $reject, $notify) use ($onFulfilled, $onRejected, $onProgress) {
             if ($onProgress) {
-                $progressHandler = static function ($update) use ($notify, $onProgress) {
+                $progressHandler = static function($update) use ($notify, $onProgress) {
                     try {
                         $notify($onProgress($update));
                     } catch (\Throwable $e) {
@@ -129,7 +129,7 @@ 
                 $progressHandler = $notify;
             }
 
-            $this->handlers[] = static function (ExtendedPromiseInterface $promise) use ($onFulfilled, $onRejected, $resolve, $reject, $progressHandler) {
+            $this->handlers[] = static function(ExtendedPromiseInterface $promise) use ($onFulfilled, $onRejected, $resolve, $reject, $progressHandler) {
                 $promise
                     ->then($onFulfilled, $onRejected)
                     ->done($resolve, $reject, $progressHandler);
@@ -222,23 +222,23 @@ 
                 // garbage cycles if any callback creates an Exception.
                 // These assumptions are covered by the test suite, so if you ever feel like
                 // refactoring this, go ahead, any alternative suggestions are welcome!
-                $target =& $this;
-                $progressHandlers =& $this->progressHandlers;
+                $target = & $this;
+                $progressHandlers = & $this->progressHandlers;
 
                 $callback(
-                    static function ($value = null) use (&$target) {
+                    static function($value = null) use (&$target) {
                         if ($target !== null) {
                             $target->settle(resolve($value));
                             $target = null;
                         }
                     },
-                    static function ($reason = null) use (&$target) {
+                    static function($reason = null) use (&$target) {
                         if ($target !== null) {
                             $target->reject($reason);
                             $target = null;
                         }
                     },
-                    static function ($update = null) use (&$progressHandlers) {
+                    static function($update = null) use (&$progressHandlers) {
                         foreach ($progressHandlers as $handler) {
                             $handler($update);
                         }

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

Spacing +2 added lines, -2 removed lines

@@ -61,8 +61,8 @@
 
     public function always(callable $onFulfilledOrRejected)
     {
-        return $this->then(null, function ($reason) use ($onFulfilledOrRejected) {
-            return resolve($onFulfilledOrRejected())->then(function () use ($reason) {
+        return $this->then(null, function($reason) use ($onFulfilledOrRejected) {
+            return resolve($onFulfilledOrRejected())->then(function() use ($reason) {
                 return new RejectedPromise($reason);
             });
         });

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

Spacing +2 added lines, -2 removed lines

@@ -53,8 +53,8 @@
 
     public function always(callable $onFulfilledOrRejected)
     {
-        return $this->then(function ($value) use ($onFulfilledOrRejected) {
-            return resolve($onFulfilledOrRejected())->then(function () use ($value) {
+        return $this->then(function($value) use ($onFulfilledOrRejected) {
+            return resolve($onFulfilledOrRejected())->then(function() use ($value) {
                 return $value;
             });
         });

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

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
     public function promise()
     {
         if (null === $this->promise) {
-            $this->promise = new Promise(function ($resolve, $reject, $notify) {
+            $this->promise = new Promise(function($resolve, $reject, $notify) {
                 $this->resolveCallback = $resolve;
                 $this->rejectCallback  = $reject;
                 $this->notifyCallback  = $notify;

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

Spacing +2 added lines, -2 removed lines

@@ -78,7 +78,7 @@ 
                 $error = \error_get_last();
                 if (\preg_match('/\(([^\)]+)\)|\[(\d+)\]: (.*)/', $error['message'], $match)) {
                     $errstr = isset($match[3]) ? $match['3'] : $match[1];
-                    $errno = isset($match[2]) ? (int)$match[2] : 0;
+                    $errno = isset($match[2]) ? (int) $match[2] : 0;
                 }
             }
 
@@ -118,7 +118,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/SocketServer.php

Spacing +2 added lines, -2 removed lines

@@ -68,10 +68,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));
         });
     }

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

Spacing +1 added lines, -1 removed lines

@@ -178,7 +178,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/TcpConnector.php

Spacing +3 added lines, -3 removed lines

@@ -98,8 +98,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
@@ -139,7 +139,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/HappyEyeBallsConnectionBuilder.php

Spacing +12 added lines, -12 removed lines

@@ -67,9 +67,9 @@ 
     {
         $timer = null;
         $that = $this;
-        return new Promise\Promise(function ($resolve, $reject) use ($that, &$timer) {
-            $lookupResolve = function ($type) use ($that, $resolve, $reject) {
-                return function (array $ips) use ($that, $type, $resolve, $reject) {
+        return new Promise\Promise(function($resolve, $reject) use ($that, &$timer) {
+            $lookupResolve = function($type) use ($that, $resolve, $reject) {
+                return function(array $ips) use ($that, $type, $resolve, $reject) {
                     unset($that->resolverPromises[$type]);
                     $that->resolved[$type] = true;
 
@@ -83,7 +83,7 @@ 
             };
 
             $that->resolverPromises[Message::TYPE_AAAA] = $that->resolve(Message::TYPE_AAAA, $reject)->then($lookupResolve(Message::TYPE_AAAA));
-            $that->resolverPromises[Message::TYPE_A] = $that->resolve(Message::TYPE_A, $reject)->then(function (array $ips) use ($that, &$timer) {
+            $that->resolverPromises[Message::TYPE_A] = $that->resolve(Message::TYPE_A, $reject)->then(function(array $ips) use ($that, &$timer) {
                 // happy path: IPv6 has resolved already (or could not resolve), continue with IPv4 addresses
                 if ($that->resolved[Message::TYPE_AAAA] === true || !$ips) {
                     return $ips;
@@ -91,18 +91,18 @@ 
 
                 // Otherwise delay processing IPv4 lookup until short timer passes or IPv6 resolves in the meantime
                 $deferred = new Promise\Deferred();
-                $timer = $that->loop->addTimer($that::RESOLUTION_DELAY, function () use ($deferred, $ips) {
+                $timer = $that->loop->addTimer($that::RESOLUTION_DELAY, function() use ($deferred, $ips) {
                     $deferred->resolve($ips);
                 });
 
-                $that->resolverPromises[Message::TYPE_AAAA]->then(function () use ($that, $timer, $deferred, $ips) {
+                $that->resolverPromises[Message::TYPE_AAAA]->then(function() use ($that, $timer, $deferred, $ips) {
                     $that->loop->cancelTimer($timer);
                     $deferred->resolve($ips);
                 });
 
                 return $deferred->promise();
             })->then($lookupResolve(Message::TYPE_A));
-        }, function ($_, $reject) use ($that, &$timer) {
+        }, function($_, $reject) use ($that, &$timer) {
             $reject(new \RuntimeException(
                 'Connection to ' . $that->uri . ' cancelled' . (!$that->connectionPromises ? ' during DNS lookup' : '') . ' (ECONNABORTED)',
                 \defined('SOCKET_ECONNABORTED') ? \SOCKET_ECONNABORTED : 103
@@ -127,7 +127,7 @@ 
     public function resolve($type, $reject)
     {
         $that = $this;
-        return $that->resolver->resolveAll($that->host, $type)->then(null, function (\Exception $e) use ($type, $reject, $that) {
+        return $that->resolver->resolveAll($that->host, $type)->then(null, function(\Exception $e) use ($type, $reject, $that) {
             unset($that->resolverPromises[$type]);
             $that->resolved[$type] = true;
 
@@ -171,13 +171,13 @@ 
         $index = \key($this->connectionPromises);
 
         $that = $this;
-        $that->connectionPromises[$index]->then(function ($connection) use ($that, $index, $resolve) {
+        $that->connectionPromises[$index]->then(function($connection) use ($that, $index, $resolve) {
             unset($that->connectionPromises[$index]);
 
             $that->cleanUp();
 
             $resolve($connection);
-        }, function (\Exception $e) use ($that, $index, $ip, $resolve, $reject) {
+        }, function(\Exception $e) use ($that, $index, $ip, $resolve, $reject) {
             unset($that->connectionPromises[$index]);
 
             $that->failureCount++;
@@ -219,7 +219,7 @@ 
         // Allow next connection attempt in 100ms: https://tools.ietf.org/html/rfc8305#section-5
         // Only start timer when more IPs are queued or when DNS query is still pending (might add more IPs)
         if ($this->nextAttemptTimer === null && (\count($this->connectQueue) > 0 || $this->resolved[Message::TYPE_A] === false || $this->resolved[Message::TYPE_AAAA] === false)) {
-            $this->nextAttemptTimer = $this->loop->addTimer(self::CONNECTION_ATTEMPT_DELAY, function () use ($that, $resolve, $reject) {
+            $this->nextAttemptTimer = $this->loop->addTimer(self::CONNECTION_ATTEMPT_DELAY, function() use ($that, $resolve, $reject) {
                 $that->nextAttemptTimer = null;
 
                 if ($that->connectQueue) {
@@ -328,6 +328,6 @@ 
             $message = ': ' . $message;
         }
 
-        return 'Connection to ' . $this->uri . ' failed'  . $message;
+        return 'Connection to ' . $this->uri . ' failed' . $message;
     }
 }