deployphp / deployer

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

Spacing +3 added lines, -3 removed lines

@@ -24,8 +24,8 @@ 
         $this->size = $size;
 
         $that = $this;
-        $pos =& $this->position;
-        $input->on('data', function ($data) use ($that, &$pos, $size) {
+        $pos = & $this->position;
+        $input->on('data', function($data) use ($that, &$pos, $size) {
             $that->emit('data', array($data));
 
             $pos += \strlen($data);
@@ -33,7 +33,7 @@ 
                 $that->handleEnd();
             }
         });
-        $input->on('error', function ($error) use ($that) {
+        $input->on('error', function($error) use ($that) {
             $that->emit('error', array($error));
             $that->close();
         });

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

Indentation +41 added lines, -41 removed lines

@@ -66,46 +66,46 @@
         return $dest;
     }
 
-     public function close()
-     {
-         if ($this->closed) {
-             return;
-         }
-
-         $this->closed = true;
-
-         // stop listening for incoming events
-         $this->input->removeListener('data', array($this, 'handleData'));
-         $this->input->removeListener('error', array($this, 'handleError'));
-         $this->input->removeListener('end', array($this, 'handleEnd'));
-         $this->input->removeListener('close', array($this, 'close'));
-
-         // resume the stream to ensure we discard everything from incoming connection
-         if ($this->paused) {
-             $this->paused = false;
-             $this->input->resume();
-         }
-
-         $this->emit('close');
-         $this->removeAllListeners();
-     }
-
-     /** @internal */
-     public function handleData($data)
-     {
+        public function close()
+        {
+            if ($this->closed) {
+                return;
+            }
+
+            $this->closed = true;
+
+            // stop listening for incoming events
+            $this->input->removeListener('data', array($this, 'handleData'));
+            $this->input->removeListener('error', array($this, 'handleError'));
+            $this->input->removeListener('end', array($this, 'handleEnd'));
+            $this->input->removeListener('close', array($this, 'close'));
+
+            // resume the stream to ensure we discard everything from incoming connection
+            if ($this->paused) {
+                $this->paused = false;
+                $this->input->resume();
+            }
+
+            $this->emit('close');
+            $this->removeAllListeners();
+        }
+
+        /** @internal */
+        public function handleData($data)
+        {
         $this->emit('data', array($data));
-     }
-
-     /** @internal */
-     public function handleEnd()
-     {
-         $this->emit('end');
-         $this->close();
-     }
-
-     /** @internal */
-     public function handleError(\Exception $e)
-     {
-         $this->emit('error', array($e));
-     }
+        }
+
+        /** @internal */
+        public function handleEnd()
+        {
+            $this->emit('end');
+            $this->close();
+        }
+
+        /** @internal */
+        public function handleError(\Exception $e)
+        {
+            $this->emit('error', array($e));
+        }
 }

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