deployphp / deployer

deps/vendor/react/promise-stream/src/UnwrapReadableStream.php

Spacing +9 added lines, -9 removed lines

@@ -27,17 +27,17 @@ 
     public function __construct(PromiseInterface $promise)
     {
         $out = $this;
-        $closed =& $this->closed;
+        $closed = & $this->closed;
 
         $this->promise = $promise->then(
-            function ($stream) {
+            function($stream) {
                 if (!$stream instanceof ReadableStreamInterface) {
                     throw new InvalidArgumentException('Not a readable stream');
                 }
                 return $stream;
             }
         )->then(
-            function (ReadableStreamInterface $stream) use ($out, &$closed) {
+            function(ReadableStreamInterface $stream) use ($out, &$closed) {
                 // stream is already closed, make sure to close output stream
                 if (!$stream->isReadable()) {
                     $out->close();
@@ -51,12 +51,12 @@ 
                 }
 
                 // stream any writes into output stream
-                $stream->on('data', function ($data) use ($out) {
+                $stream->on('data', function($data) use ($out) {
                     $out->emit('data', array($data, $out));
                 });
 
                 // forward end events and close
-                $stream->on('end', function () use ($out, &$closed) {
+                $stream->on('end', function() use ($out, &$closed) {
                     if (!$closed) {
                         $out->emit('end', array($out));
                         $out->close();
@@ -64,7 +64,7 @@ 
                 });
 
                 // error events cancel output stream
-                $stream->on('error', function ($error) use ($out) {
+                $stream->on('error', function($error) use ($out) {
                     $out->emit('error', array($error, $out));
                     $out->close();
                 });
@@ -75,7 +75,7 @@ 
 
                 return $stream;
             },
-            function ($e) use ($out, &$closed) {
+            function($e) use ($out, &$closed) {
                 if (!$closed) {
                     $out->emit('error', array($e, $out));
                     $out->close();
@@ -95,7 +95,7 @@ 
     public function pause()
     {
         if ($this->promise !== null) {
-            $this->promise->then(function (ReadableStreamInterface $stream) {
+            $this->promise->then(function(ReadableStreamInterface $stream) {
                 $stream->pause();
             });
         }
@@ -104,7 +104,7 @@ 
     public function resume()
     {
         if ($this->promise !== null) {
-            $this->promise->then(function (ReadableStreamInterface $stream) {
+            $this->promise->then(function(ReadableStreamInterface $stream) {
                 $stream->resume();
             });
         }

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

Spacing +18 added lines, -18 removed lines

@@ -56,8 +56,8 @@ 
 
     $buffer = '';
 
-    $promise = new Promise\Promise(function ($resolve, $reject) use ($stream, $maxLength, &$buffer, &$bufferer) {
-        $bufferer = function ($data) use (&$buffer, $reject, $maxLength) {
+    $promise = new Promise\Promise(function($resolve, $reject) use ($stream, $maxLength, &$buffer, &$bufferer) {
+        $bufferer = function($data) use (&$buffer, $reject, $maxLength) {
             $buffer .= $data;
 
             if ($maxLength !== null && isset($buffer[$maxLength])) {
@@ -67,7 +67,7 @@ 
 
         $stream->on('data', $bufferer);
 
-        $stream->on('error', function (\Exception $e) use ($reject) {
+        $stream->on('error', function(\Exception $e) use ($reject) {
             $reject(new \RuntimeException(
                 'An error occured on the underlying stream while buffering: ' . $e->getMessage(),
                 $e->getCode(),
@@ -75,14 +75,14 @@ 
             ));
         });
 
-        $stream->on('close', function () use ($resolve, &$buffer) {
+        $stream->on('close', function() use ($resolve, &$buffer) {
             $resolve($buffer);
         });
-    }, function ($_, $reject) {
+    }, function($_, $reject) {
         $reject(new \RuntimeException('Cancelled buffering'));
     });
 
-    return $promise->then(null, function (\Exception $error) use (&$buffer, $bufferer, $stream) {
+    return $promise->then(null, function(\Exception $error) use (&$buffer, $bufferer, $stream) {
         // promise rejected => clear buffer and buffering
         $buffer = '';
         $stream->removeListener('data', $bufferer);
@@ -138,15 +138,15 @@ 
         }
     }
 
-    return new Promise\Promise(function ($resolve, $reject) use ($stream, $event, &$listener) {
-        $listener = function ($data = null) use ($stream, $event, &$listener, $resolve) {
+    return new Promise\Promise(function($resolve, $reject) use ($stream, $event, &$listener) {
+        $listener = function($data = null) use ($stream, $event, &$listener, $resolve) {
             $stream->removeListener($event, $listener);
             $resolve($data);
         };
         $stream->on($event, $listener);
 
         if ($event !== 'error') {
-            $stream->on('error', function (\Exception $e) use ($stream, $event, $listener, $reject) {
+            $stream->on('error', function(\Exception $e) use ($stream, $event, $listener, $reject) {
                 $stream->removeListener($event, $listener);
                 $reject(new \RuntimeException(
                     'An error occured on the underlying stream while waiting for event: ' . $e->getMessage(),
@@ -156,11 +156,11 @@ 
             });
         }
 
-        $stream->on('close', function () use ($stream, $event, $listener, $reject) {
+        $stream->on('close', function() use ($stream, $event, $listener, $reject) {
             $stream->removeListener($event, $listener);
             $reject(new \RuntimeException('Stream closed'));
         });
-    }, function ($_, $reject) use ($stream, $event, &$listener) {
+    }, function($_, $reject) use ($stream, $event, &$listener) {
         $stream->removeListener($event, $listener);
         $reject(new \RuntimeException('Operation cancelled'));
     });
@@ -211,13 +211,13 @@ 
     }
 
     $buffer = array();
-    $bufferer = function ($data = null) use (&$buffer) {
-        $buffer []= $data;
+    $bufferer = function($data = null) use (&$buffer) {
+        $buffer [] = $data;
     };
     $stream->on($event, $bufferer);
 
-    $promise = new Promise\Promise(function ($resolve, $reject) use ($stream, &$buffer) {
-        $stream->on('error', function (\Exception $e) use ($reject) {
+    $promise = new Promise\Promise(function($resolve, $reject) use ($stream, &$buffer) {
+        $stream->on('error', function(\Exception $e) use ($reject) {
             $reject(new \RuntimeException(
                 'An error occured on the underlying stream while buffering: ' . $e->getMessage(),
                 $e->getCode(),
@@ -225,14 +225,14 @@ 
             ));
         });
 
-        $stream->on('close', function () use ($resolve, &$buffer) {
+        $stream->on('close', function() use ($resolve, &$buffer) {
             $resolve($buffer);
         });
-    }, function ($_, $reject) {
+    }, function($_, $reject) {
         $reject(new \RuntimeException('Cancelled buffering'));
     });
 
-    return $promise->then(null, function ($error) use (&$buffer, $bufferer, $stream, $event) {
+    return $promise->then(null, function($error) use (&$buffer, $bufferer, $stream, $event) {
         // promise rejected => clear buffer and buffering
         $buffer = array();
         $stream->removeListener($event, $bufferer);

deps/vendor/react/promise-stream/src/UnwrapWritableStream.php

Spacing +9 added lines, -9 removed lines

@@ -28,20 +28,20 @@ 
     public function __construct(PromiseInterface $promise)
     {
         $out = $this;
-        $store  =& $this->stream;
-        $buffer =& $this->buffer;
-        $ending =& $this->ending;
-        $closed =& $this->closed;
+        $store  = & $this->stream;
+        $buffer = & $this->buffer;
+        $ending = & $this->ending;
+        $closed = & $this->closed;
 
         $this->promise = $promise->then(
-            function ($stream) {
+            function($stream) {
                 if (!$stream instanceof WritableStreamInterface) {
                     throw new InvalidArgumentException('Not a writable stream');
                 }
                 return $stream;
             }
         )->then(
-            function (WritableStreamInterface $stream) use ($out, &$store, &$buffer, &$ending, &$closed) {
+            function(WritableStreamInterface $stream) use ($out, &$store, &$buffer, &$ending, &$closed) {
                 // stream is already closed, make sure to close output stream
                 if (!$stream->isWritable()) {
                     $out->close();
@@ -55,12 +55,12 @@ 
                 }
 
                 // forward drain events for back pressure
-                $stream->on('drain', function () use ($out) {
+                $stream->on('drain', function() use ($out) {
                     $out->emit('drain', array($out));
                 });
 
                 // error events cancel output stream
-                $stream->on('error', function ($error) use ($out) {
+                $stream->on('error', function($error) use ($out) {
                     $out->emit('error', array($error, $out));
                     $out->close();
                 });
@@ -93,7 +93,7 @@ 
 
                 return $stream;
             },
-            function ($e) use ($out, &$closed) {
+            function($e) use ($out, &$closed) {
                 if (!$closed) {
                     $out->emit('error', array($e, $out));
                     $out->close();

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

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
 
     public function query(Query $query)
     {
-        return Timer\timeout($this->executor->query($query), $this->timeout, $this->loop)->then(null, function ($e) use ($query) {
+        return Timer\timeout($this->executor->query($query), $this->timeout, $this->loop)->then(null, function($e) use ($query) {
             if ($e instanceof Timer\TimeoutException) {
                 $e = new TimeoutException(sprintf("DNS query for %s timed out", $query->describe()), 0, $e);
             }

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

Spacing +4 added lines, -4 removed lines

@@ -132,7 +132,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
             ));
         }
@@ -149,13 +149,13 @@ 
             $error = \error_get_last();
             \preg_match('/errno=(\d+) (.+)/', $error['message'], $m);
             return \React\Promise\reject(new \RuntimeException(
-                'DNS query for ' . $query->describe() . ' failed: Unable to send query to DNS server ' . $this->nameserver . ' ('  . (isset($m[2]) ? $m[2] : $error['message']) . ')',
+                'DNS query for ' . $query->describe() . ' failed: Unable to send query to DNS server ' . $this->nameserver . ' (' . (isset($m[2]) ? $m[2] : $error['message']) . ')',
                 isset($m[1]) ? (int) $m[1] : 0
             ));
         }
 
         $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);
@@ -166,7 +166,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/dns/src/Query/TcpTransportExecutor.php

Spacing +5 added lines, -5 removed lines

@@ -176,7 +176,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
                 ));
             }
@@ -201,9 +201,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]);
@@ -291,7 +291,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);
@@ -359,7 +359,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/RetryExecutor.php

Spacing +3 added lines, -3 removed lines

@@ -24,19 +24,19 @@
 
     public function tryQuery(Query $query, $retries)
     {
-        $deferred = new Deferred(function () use (&$promise) {
+        $deferred = new Deferred(function() use (&$promise) {
             if ($promise instanceof CancellablePromiseInterface || (!\interface_exists('React\Promise\CancellablePromiseInterface') && \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/promise-timer/src/functions.php

Spacing +9 added lines, -9 removed lines

@@ -147,7 +147,7 @@ 
     if ($promise instanceof CancellablePromiseInterface || (!\interface_exists('React\Promise\CancellablePromiseInterface') && \method_exists($promise, 'cancel'))) {
         // pass promise by reference to clean reference after cancellation handler
         // has been invoked once in order to avoid garbage references in call stack.
-        $canceller = function () use (&$promise) {
+        $canceller = function() use (&$promise) {
             $promise->cancel();
             $promise = null;
         };
@@ -157,15 +157,15 @@ 
         $loop = Loop::get();
     }
 
-    return new Promise(function ($resolve, $reject) use ($loop, $time, $promise) {
+    return new Promise(function($resolve, $reject) use ($loop, $time, $promise) {
         $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);
             }
@@ -179,7 +179,7 @@ 
         }
 
         // start timeout timer which will cancel the input promise
-        $timer = $loop->addTimer($time, function () use ($time, &$promise, $reject) {
+        $timer = $loop->addTimer($time, function() use ($time, &$promise, $reject) {
             $reject(new TimeoutException($time, 'Timed out after ' . $time . ' seconds'));
 
             // try to invoke cancellation handler of input promise and then clean
@@ -233,12 +233,12 @@ 
     }
 
     $timer = null;
-    return new Promise(function ($resolve) use ($loop, $time, &$timer) {
+    return new Promise(function($resolve) use ($loop, $time, &$timer) {
         // resolve the promise when the timer fires in $time seconds
-        $timer = $loop->addTimer($time, function () use ($resolve) {
+        $timer = $loop->addTimer($time, function() use ($resolve) {
             $resolve();
         });
-    }, function () use (&$timer, $loop) {
+    }, function() use (&$timer, $loop) {
         // cancelling this promise will cancel the timer, clean the reference
         // in order to avoid garbage references in call stack and then reject.
         $loop->cancelTimer($timer);
@@ -329,7 +329,7 @@ 
  */
 function reject($time, LoopInterface $loop = null)
 {
-    return sleep($time, $loop)->then(function () use ($time) {
+    return sleep($time, $loop)->then(function() use ($time) {
         throw new TimeoutException($time, 'Timer expired after ' . $time . ' seconds');
     });
 }

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

Spacing +1 added lines, -1 removed lines

@@ -197,7 +197,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 ...