deployphp / deployer

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);
         };
 

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

Spacing +3 added lines, -3 removed lines

@@ -198,7 +198,7 @@ 
                     // Ensure we do not exceed maximum integer size, which may
                     // cause the loop to tick once every ~35min on 32bit systems.
                     $timeout *= self::MICROSECONDS_PER_SECOND;
-                    $timeout = $timeout > \PHP_INT_MAX ? \PHP_INT_MAX : (int)$timeout;
+                    $timeout = $timeout > \PHP_INT_MAX ? \PHP_INT_MAX : (int) $timeout;
                 }
 
             // The only possible event is stream or signal activity, so wait forever ...
@@ -288,11 +288,11 @@ 
             }
 
             /** @var ?callable $previous */
-            $previous = \set_error_handler(function ($errno, $errstr) use (&$previous) {
+            $previous = \set_error_handler(function($errno, $errstr) use (&$previous) {
                 // suppress warnings that occur when `stream_select()` is interrupted by a signal
                 // PHP defines `EINTR` through `ext-sockets` or `ext-pcntl`, otherwise use common default (Linux & Mac)
                 $eintr = \defined('SOCKET_EINTR') ? \SOCKET_EINTR : (\defined('PCNTL_EINTR') ? \PCNTL_EINTR : 4);
-                if ($errno === \E_WARNING && \strpos($errstr, '[' . $eintr .']: ') !== false) {
+                if ($errno === \E_WARNING && \strpos($errstr, '[' . $eintr . ']: ') !== false) {
                     return;
                 }
 

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

Spacing +4 added lines, -4 removed lines

@@ -237,7 +237,7 @@ 
     {
         $that = $this;
         $timers = $this->timerEvents;
-        $this->timerCallback = function ($_, $__, $timer) use ($timers, $that) {
+        $this->timerCallback = function($_, $__, $timer) use ($timers, $that) {
             \call_user_func($timer->getCallback(), $timer);
 
             // Timer already cancelled ...
@@ -268,9 +268,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 (\EV_READ === (\EV_READ & $flags) && isset($read[$key])) {

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

Indentation +1 added lines, -1 removed lines

@@ -48,7 +48,7 @@
     public function __construct($stream, $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 "+")

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,