deployphp / deployer

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

Spacing +6 added lines, -6 removed lines

@@ -55,7 +55,7 @@ 
             return;
         }
 
-        $callback = function () use ($stream, $listener) {
+        $callback = function() use ($stream, $listener) {
             \call_user_func($listener, $stream);
         };
 
@@ -71,7 +71,7 @@ 
             return;
         }
 
-        $callback = function () use ($stream, $listener) {
+        $callback = function() use ($stream, $listener) {
             \call_user_func($listener, $stream);
         };
 
@@ -105,11 +105,11 @@ 
 
     public function addTimer($interval, $callback)
     {
-        $timer = new Timer( $interval, $callback, false);
+        $timer = new Timer($interval, $callback, false);
 
         $that = $this;
         $timers = $this->timerEvents;
-        $callback = function () use ($timer, $timers, $that) {
+        $callback = function() use ($timer, $timers, $that) {
             \call_user_func($timer->getCallback(), $timer);
 
             if ($timers->contains($timer)) {
@@ -128,7 +128,7 @@ 
     {
         $timer = new Timer($interval, $callback, true);
 
-        $callback = function () use ($timer) {
+        $callback = function() use ($timer) {
             \call_user_func($timer->getCallback(), $timer);
         };
 
@@ -158,7 +158,7 @@ 
 
         if (!isset($this->signalEvents[$signal])) {
             $signals = $this->signals;
-            $this->signalEvents[$signal] = new SignalEvent(function () use ($signals, $signal) {
+            $this->signalEvents[$signal] = new SignalEvent(function() use ($signals, $signal) {
                 $signals->call($signal);
             }, $signal);
             $this->loop->add($this->signalEvents[$signal]);

deps/vendor/react/stream/src/Util.php

Spacing +7 added lines, -7 removed lines

@@ -30,33 +30,33 @@ 
         $dest->emit('pipe', array($source));
 
         // forward all source data events as $dest->write()
-        $source->on('data', $dataer = function ($data) use ($source, $dest) {
+        $source->on('data', $dataer = function($data) use ($source, $dest) {
             $feedMore = $dest->write($data);
 
             if (false === $feedMore) {
                 $source->pause();
             }
         });
-        $dest->on('close', function () use ($source, $dataer) {
+        $dest->on('close', function() use ($source, $dataer) {
             $source->removeListener('data', $dataer);
             $source->pause();
         });
 
         // forward destination drain as $source->resume()
-        $dest->on('drain', $drainer = function () use ($source) {
+        $dest->on('drain', $drainer = function() use ($source) {
             $source->resume();
         });
-        $source->on('close', function () use ($dest, $drainer) {
+        $source->on('close', function() use ($dest, $drainer) {
             $dest->removeListener('drain', $drainer);
         });
 
         // forward end event from source as $dest->end()
         $end = isset($options['end']) ? $options['end'] : true;
         if ($end) {
-            $source->on('end', $ender = function () use ($dest) {
+            $source->on('end', $ender = function() use ($dest) {
                 $dest->end();
             });
-            $dest->on('close', function () use ($source, $ender) {
+            $dest->on('close', function() use ($source, $ender) {
                 $source->removeListener('end', $ender);
             });
         }
@@ -67,7 +67,7 @@ 
     public static function forwardEvents($source, $target, array $events)
     {
         foreach ($events as $event) {
-            $source->on($event, function () use ($event, $target) {
+            $source->on($event, function() use ($event, $target) {
                 $target->emit($event, \func_get_args());
             });
         }

deps/vendor/react/stream/src/ReadableResourceStream.php

Spacing +2 added lines, -2 removed lines

@@ -81,7 +81,7 @@ 
 
         $this->stream = $stream;
         $this->loop = $loop ?: Loop::get();
-        $this->bufferSize = ($readChunkSize === null) ? 65536 : (int)$readChunkSize;
+        $this->bufferSize = ($readChunkSize === null) ? 65536 : (int) $readChunkSize;
 
         $this->resume();
     }
@@ -133,7 +133,7 @@ 
     public function handleData()
     {
         $error = null;
-        \set_error_handler(function ($errno, $errstr, $errfile, $errline) use (&$error) {
+        \set_error_handler(function($errno, $errstr, $errfile, $errline) use (&$error) {
             $error = new \ErrorException(
                 $errstr,
                 0,

Indentation +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
     public function __construct($stream, LoopInterface $loop = null, $readChunkSize = null)
     {
         if (!\is_resource($stream) || \get_resource_type($stream) !== "stream") {
-             throw new InvalidArgumentException('First parameter must be a valid stream resource');
+                throw new InvalidArgumentException('First parameter must be a valid stream resource');
         }
 
         // ensure resource is opened for reading (fopen mode must contain "r" or "+")

deps/vendor/react/stream/src/WritableResourceStream.php

Spacing +3 added lines, -3 removed lines

@@ -58,8 +58,8 @@ 
 
         $this->stream = $stream;
         $this->loop = $loop ?: Loop::get();
-        $this->softLimit = ($writeBufferSoftLimit === null) ? 65536 : (int)$writeBufferSoftLimit;
-        $this->writeChunkSize = ($writeChunkSize === null) ? -1 : (int)$writeChunkSize;
+        $this->softLimit = ($writeBufferSoftLimit === null) ? 65536 : (int) $writeBufferSoftLimit;
+        $this->writeChunkSize = ($writeChunkSize === null) ? -1 : (int) $writeChunkSize;
     }
 
     public function isWritable()
@@ -126,7 +126,7 @@ 
     public function handleWrite()
     {
         $error = null;
-        \set_error_handler(function ($_, $errstr) use (&$error) {
+        \set_error_handler(function($_, $errstr) use (&$error) {
             $error = $errstr;
         });
 

deps/vendor/react/stream/src/DuplexResourceStream.php

Spacing +4 added lines, -4 removed lines

@@ -87,18 +87,18 @@ 
 
         $this->stream = $stream;
         $this->loop = $loop ?: Loop::get();
-        $this->bufferSize = ($readChunkSize === null) ? 65536 : (int)$readChunkSize;
+        $this->bufferSize = ($readChunkSize === null) ? 65536 : (int) $readChunkSize;
         $this->buffer = $buffer;
 
         $that = $this;
 
-        $this->buffer->on('error', function ($error) use ($that) {
+        $this->buffer->on('error', function($error) use ($that) {
             $that->emit('error', array($error));
         });
 
         $this->buffer->on('close', array($this, 'close'));
 
-        $this->buffer->on('drain', function () use ($that) {
+        $this->buffer->on('drain', function() use ($that) {
             $that->emit('drain');
         });
 
@@ -185,7 +185,7 @@ 
     public function handleData($stream)
     {
         $error = null;
-        \set_error_handler(function ($errno, $errstr, $errfile, $errline) use (&$error) {
+        \set_error_handler(function($errno, $errstr, $errfile, $errline) use (&$error) {
             $error = new \ErrorException(
                 $errstr,
                 0,

Indentation +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
     public function __construct($stream, LoopInterface $loop = null, $readChunkSize = null, WritableStreamInterface $buffer = null)
     {
         if (!\is_resource($stream) || \get_resource_type($stream) !== "stream") {
-             throw new InvalidArgumentException('First parameter must be a valid stream resource');
+                throw new InvalidArgumentException('First parameter must be a valid stream resource');
         }
 
         // ensure resource is opened for reading and wrting (fopen mode must contain "+")

deps/vendor/react/dns/src/Resolver/Resolver.php

Spacing +4 added lines, -4 removed lines

@@ -21,7 +21,7 @@ 
 
     public function resolve($domain)
     {
-        return $this->resolveAll($domain, Message::TYPE_A)->then(function (array $ips) {
+        return $this->resolveAll($domain, Message::TYPE_A)->then(function(array $ips) {
             return $ips[array_rand($ips)];
         });
     }
@@ -33,7 +33,7 @@ 
 
         return $this->executor->query(
             $query
-        )->then(function (Message $response) use ($query, $that) {
+        )->then(function(Message $response) use ($query, $that) {
             return $that->extractValues($query, $response);
         });
     }
@@ -133,14 +133,14 @@ 
     private function filterByField(array $answers, $field, $value)
     {
         $value = strtolower($value);
-        return array_filter($answers, function ($answer) use ($field, $value) {
+        return array_filter($answers, function($answer) use ($field, $value) {
             return $value === strtolower($answer->$field);
         });
     }
 
     private function mapRecordData(array $records)
     {
-        return array_map(function ($record) {
+        return array_map(function($record) {
             return $record->data;
         }, $records);
     }

deps/vendor/react/dns/src/Protocol/Parser.php

Spacing +2 added lines, -2 removed lines

@@ -174,7 +174,7 @@ 
             $rdata = array();
             while ($consumed < $expected) {
                 $len = ord($data[$consumed]);
-                $rdata[] = (string)substr($data, $consumed + 1, $len);
+                $rdata[] = (string) substr($data, $consumed + 1, $len);
                 $consumed += $len + 1;
             }
         } elseif (Message::TYPE_MX === $type) {
@@ -291,7 +291,7 @@ 
             \implode(
                 '.',
                 \array_map(
-                    function ($label) {
+                    function($label) {
                         return \addcslashes($label, "\0..\40.\177");
                     },
                     $labels

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

Spacing +3 added lines, -3 removed lines

@@ -66,10 +66,10 @@ 
         $stream = $this->streamExecutor;
         $pending = $this->datagramExecutor->query($query);
 
-        return new Promise(function ($resolve, $reject) use (&$pending, $stream, $query) {
+        return new Promise(function($resolve, $reject) use (&$pending, $stream, $query) {
             $pending->then(
                 $resolve,
-                function ($e) use (&$pending, $stream, $query, $resolve, $reject) {
+                function($e) use (&$pending, $stream, $query, $resolve, $reject) {
                     if ($e->getCode() === (\defined('SOCKET_EMSGSIZE') ? \SOCKET_EMSGSIZE : 90)) {
                         $pending = $stream->query($query)->then($resolve, $reject);
                     } else {
@@ -77,7 +77,7 @@ 
                     }
                 }
             );
-        }, function () use (&$pending) {
+        }, function() use (&$pending) {
             $pending->cancel();
             $pending = null;
         });

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

Spacing +4 added lines, -4 removed lines

@@ -21,8 +21,8 @@ 
         $fallback = $this->fallback;
         $promise = $this->executor->query($query);
 
-        return new Promise(function ($resolve, $reject) use (&$promise, $fallback, $query, &$cancelled) {
-            $promise->then($resolve, function (\Exception $e1) use ($fallback, $query, $resolve, $reject, &$cancelled, &$promise) {
+        return new Promise(function($resolve, $reject) use (&$promise, $fallback, $query, &$cancelled) {
+            $promise->then($resolve, function(\Exception $e1) use ($fallback, $query, $resolve, $reject, &$cancelled, &$promise) {
                 // reject if primary resolution rejected due to cancellation
                 if ($cancelled) {
                     $reject($e1);
@@ -30,7 +30,7 @@ 
                 }
 
                 // start fallback query if primary query rejected
-                $promise = $fallback->query($query)->then($resolve, function (\Exception $e2) use ($e1, $reject) {
+                $promise = $fallback->query($query)->then($resolve, function(\Exception $e2) use ($e1, $reject) {
                     $append = $e2->getMessage();
                     if (($pos = strpos($append, ':')) !== false) {
                         $append = substr($append, $pos + 2);
@@ -40,7 +40,7 @@ 
                     $reject(new \RuntimeException($e1->getMessage() . '. ' . $append));
                 });
             });
-        }, function () use (&$promise, &$cancelled) {
+        }, function() use (&$promise, &$cancelled) {
             // cancel pending query (primary or fallback)
             $cancelled = true;
             $promise->cancel();