@@ -36,7 +36,7 @@ discard block |
||
| 36 | 36 | } |
| 37 | 37 | |
| 38 | 38 | /** @var Promise<T> */ |
| 39 | - return new Promise(function (callable $resolve, callable $reject) use ($promiseOrValue): void { |
|
| 39 | + return new Promise(function(callable $resolve, callable $reject) use ($promiseOrValue): void { |
|
| 40 | 40 | $promiseOrValue->then($resolve, $reject); |
| 41 | 41 | }, $canceller); |
| 42 | 42 | } |
@@ -79,7 +79,7 @@ discard block |
||
| 79 | 79 | $cancellationQueue = new Internal\CancellationQueue(); |
| 80 | 80 | |
| 81 | 81 | /** @var Promise<array<T>> */ |
| 82 | - return new Promise(function (callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void { |
|
| 82 | + return new Promise(function(callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void { |
|
| 83 | 83 | $toResolve = 0; |
| 84 | 84 | /** @var bool */ |
| 85 | 85 | $continue = true; |
@@ -91,14 +91,14 @@ discard block |
||
| 91 | 91 | ++$toResolve; |
| 92 | 92 | |
| 93 | 93 | resolve($promiseOrValue)->then( |
| 94 | - function ($value) use ($i, &$values, &$toResolve, &$continue, $resolve): void { |
|
| 94 | + function($value) use ($i, &$values, &$toResolve, &$continue, $resolve): void { |
|
| 95 | 95 | $values[$i] = $value; |
| 96 | 96 | |
| 97 | 97 | if (0 === --$toResolve && !$continue) { |
| 98 | 98 | $resolve($values); |
| 99 | 99 | } |
| 100 | 100 | }, |
| 101 | - function (\Throwable $reason) use (&$continue, $reject): void { |
|
| 101 | + function(\Throwable $reason) use (&$continue, $reject): void { |
|
| 102 | 102 | $continue = false; |
| 103 | 103 | $reject($reason); |
| 104 | 104 | } |
@@ -132,13 +132,13 @@ discard block |
||
| 132 | 132 | $cancellationQueue = new Internal\CancellationQueue(); |
| 133 | 133 | |
| 134 | 134 | /** @var Promise<T> */ |
| 135 | - return new Promise(function (callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void { |
|
| 135 | + return new Promise(function(callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void { |
|
| 136 | 136 | $continue = true; |
| 137 | 137 | |
| 138 | 138 | foreach ($promisesOrValues as $promiseOrValue) { |
| 139 | 139 | $cancellationQueue->enqueue($promiseOrValue); |
| 140 | 140 | |
| 141 | - resolve($promiseOrValue)->then($resolve, $reject)->finally(function () use (&$continue): void { |
|
| 141 | + resolve($promiseOrValue)->then($resolve, $reject)->finally(function() use (&$continue): void { |
|
| 142 | 142 | $continue = false; |
| 143 | 143 | }); |
| 144 | 144 | |
@@ -169,7 +169,7 @@ discard block |
||
| 169 | 169 | $cancellationQueue = new Internal\CancellationQueue(); |
| 170 | 170 | |
| 171 | 171 | /** @var Promise<T> */ |
| 172 | - return new Promise(function (callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void { |
|
| 172 | + return new Promise(function(callable $resolve, callable $reject) use ($promisesOrValues, $cancellationQueue): void { |
|
| 173 | 173 | $toReject = 0; |
| 174 | 174 | $continue = true; |
| 175 | 175 | $reasons = []; |
@@ -179,11 +179,11 @@ discard block |
||
| 179 | 179 | ++$toReject; |
| 180 | 180 | |
| 181 | 181 | resolve($promiseOrValue)->then( |
| 182 | - function ($value) use ($resolve, &$continue): void { |
|
| 182 | + function($value) use ($resolve, &$continue): void { |
|
| 183 | 183 | $continue = false; |
| 184 | 184 | $resolve($value); |
| 185 | 185 | }, |
| 186 | - function (\Throwable $reason) use ($i, &$reasons, &$toReject, $reject, &$continue): void { |
|
| 186 | + function(\Throwable $reason) use ($i, &$reasons, &$toReject, $reject, &$continue): void { |
|
| 187 | 187 | $reasons[$i] = $reason; |
| 188 | 188 | |
| 189 | 189 | if (0 === --$toReject && !$continue) { |
@@ -61,7 +61,7 @@ discard block |
||
| 61 | 61 | |
| 62 | 62 | return new static( |
| 63 | 63 | $this->resolver($onFulfilled, $onRejected), |
| 64 | - static function () use (&$parent): void { |
|
| 64 | + static function() use (&$parent): void { |
|
| 65 | 65 | assert($parent instanceof self); |
| 66 | 66 | --$parent->requiredCancelRequests; |
| 67 | 67 | |
@@ -80,9 +80,9 @@ discard block |
||
| 80 | 80 | * @param callable(TThrowable): (PromiseInterface<TRejected>|TRejected) $onRejected |
| 81 | 81 | * @return PromiseInterface<T|TRejected> |
| 82 | 82 | */ |
| 83 | - public function catch(callable $onRejected): PromiseInterface |
|
| 83 | + public function catch (callable $onRejected): PromiseInterface |
|
| 84 | 84 | { |
| 85 | - return $this->then(null, static function (\Throwable $reason) use ($onRejected) { |
|
| 85 | + return $this->then(null, static function(\Throwable $reason) use ($onRejected) { |
|
| 86 | 86 | if (!_checkTypehint($onRejected, $reason)) { |
| 87 | 87 | return new RejectedPromise($reason); |
| 88 | 88 | } |
@@ -96,12 +96,12 @@ discard block |
||
| 96 | 96 | |
| 97 | 97 | public function finally(callable $onFulfilledOrRejected): PromiseInterface |
| 98 | 98 | { |
| 99 | - return $this->then(static function ($value) use ($onFulfilledOrRejected): PromiseInterface { |
|
| 100 | - return resolve($onFulfilledOrRejected())->then(function () use ($value) { |
|
| 99 | + return $this->then(static function($value) use ($onFulfilledOrRejected): PromiseInterface { |
|
| 100 | + return resolve($onFulfilledOrRejected())->then(function() use ($value) { |
|
| 101 | 101 | return $value; |
| 102 | 102 | }); |
| 103 | - }, static function (\Throwable $reason) use ($onFulfilledOrRejected): PromiseInterface { |
|
| 104 | - return resolve($onFulfilledOrRejected())->then(function () use ($reason): RejectedPromise { |
|
| 103 | + }, static function(\Throwable $reason) use ($onFulfilledOrRejected): PromiseInterface { |
|
| 104 | + return resolve($onFulfilledOrRejected())->then(function() use ($reason): RejectedPromise { |
|
| 105 | 105 | return new RejectedPromise($reason); |
| 106 | 106 | }); |
| 107 | 107 | }); |
@@ -168,12 +168,12 @@ discard block |
||
| 168 | 168 | |
| 169 | 169 | private function resolver(?callable $onFulfilled = null, ?callable $onRejected = null): callable |
| 170 | 170 | { |
| 171 | - return function (callable $resolve, callable $reject) use ($onFulfilled, $onRejected): void { |
|
| 172 | - $this->handlers[] = static function (PromiseInterface $promise) use ($onFulfilled, $onRejected, $resolve, $reject): void { |
|
| 171 | + return function(callable $resolve, callable $reject) use ($onFulfilled, $onRejected) : void { |
|
| 172 | + $this->handlers[] = static function(PromiseInterface $promise) use ($onFulfilled, $onRejected, $resolve, $reject) : void { |
|
| 173 | 173 | $promise = $promise->then($onFulfilled, $onRejected); |
| 174 | 174 | |
| 175 | 175 | if ($promise instanceof self && $promise->result === null) { |
| 176 | - $promise->handlers[] = static function (PromiseInterface $promise) use ($resolve, $reject): void { |
|
| 176 | + $promise->handlers[] = static function(PromiseInterface $promise) use ($resolve, $reject): void { |
|
| 177 | 177 | $promise->then($resolve, $reject); |
| 178 | 178 | }; |
| 179 | 179 | } else { |
@@ -278,16 +278,16 @@ discard block |
||
| 278 | 278 | // garbage cycles if any callback creates an Exception. |
| 279 | 279 | // These assumptions are covered by the test suite, so if you ever feel like |
| 280 | 280 | // refactoring this, go ahead, any alternative suggestions are welcome! |
| 281 | - $target =& $this; |
|
| 281 | + $target = & $this; |
|
| 282 | 282 | |
| 283 | 283 | $callback( |
| 284 | - static function ($value) use (&$target): void { |
|
| 284 | + static function($value) use (&$target): void { |
|
| 285 | 285 | if ($target !== null) { |
| 286 | 286 | $target->settle(resolve($value)); |
| 287 | 287 | $target = null; |
| 288 | 288 | } |
| 289 | 289 | }, |
| 290 | - static function (\Throwable $reason) use (&$target): void { |
|
| 290 | + static function(\Throwable $reason) use (&$target): void { |
|
| 291 | 291 | if ($target !== null) { |
| 292 | 292 | $target->reject($reason); |
| 293 | 293 | $target = null; |
@@ -1,5 +1,5 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | 3 | if (!\function_exists('React\Promise\resolve')) { |
| 4 | - require __DIR__.'/functions.php'; |
|
| 4 | + require __DIR__ . '/functions.php'; |
|
| 5 | 5 | } |
@@ -22,6 +22,6 @@ |
||
| 22 | 22 | */ |
| 23 | 23 | function trigger_deprecation(string $package, string $version, string $message, mixed ...$args): void |
| 24 | 24 | { |
| 25 | - @trigger_error(($package || $version ? "Since $package $version: " : '').($args ? vsprintf($message, $args) : $message), \E_USER_DEPRECATED); |
|
| 25 | + @trigger_error(($package || $version ? "Since $package $version: " : '') . ($args ? vsprintf($message, $args) : $message), \E_USER_DEPRECATED); |
|
| 26 | 26 | } |
| 27 | 27 | } |
@@ -12,7 +12,7 @@ |
||
| 12 | 12 | use Symfony\Polyfill\Ctype as p; |
| 13 | 13 | |
| 14 | 14 | if (\PHP_VERSION_ID >= 80000) { |
| 15 | - return require __DIR__.'/bootstrap80.php'; |
|
| 15 | + return require __DIR__ . '/bootstrap80.php'; |
|
| 16 | 16 | } |
| 17 | 17 | |
| 18 | 18 | if (!function_exists('ctype_alnum')) { |
@@ -220,7 +220,7 @@ |
||
| 220 | 220 | } |
| 221 | 221 | |
| 222 | 222 | if (\PHP_VERSION_ID >= 80100) { |
| 223 | - @trigger_error($function.'(): Argument of type int will be interpreted as string in the future', \E_USER_DEPRECATED); |
|
| 223 | + @trigger_error($function . '(): Argument of type int will be interpreted as string in the future', \E_USER_DEPRECATED); |
|
| 224 | 224 | } |
| 225 | 225 | |
| 226 | 226 | if ($int < 0) { |
@@ -19,7 +19,7 @@ |
||
| 19 | 19 | function is_countable($value) { return is_array($value) || $value instanceof Countable || $value instanceof ResourceBundle || $value instanceof SimpleXmlElement; } |
| 20 | 20 | } |
| 21 | 21 | if (!function_exists('hrtime')) { |
| 22 | - require_once __DIR__.'/Php73.php'; |
|
| 22 | + require_once __DIR__ . '/Php73.php'; |
|
| 23 | 23 | p\Php73::$startAt = (int) microtime(true); |
| 24 | 24 | function hrtime($as_number = false) { return p\Php73::hrtime($as_number); } |
| 25 | 25 | } |
@@ -54,7 +54,7 @@ |
||
| 54 | 54 | return $class; |
| 55 | 55 | } |
| 56 | 56 | |
| 57 | - return (get_parent_class($class) ?: key(class_implements($class)) ?: 'class').'@anonymous'; |
|
| 57 | + return (get_parent_class($class) ?: key(class_implements($class)) ?: 'class') . '@anonymous'; |
|
| 58 | 58 | } |
| 59 | 59 | |
| 60 | 60 | public static function get_resource_id($res): int |
@@ -20,7 +20,7 @@ discard block |
||
| 20 | 20 | public function __construct(string $data, string $postname, string $mime = 'application/octet-stream') |
| 21 | 21 | { |
| 22 | 22 | $this->data = $data; |
| 23 | - parent::__construct('data://application/octet-stream;base64,'.base64_encode($data), $mime, $postname); |
|
| 23 | + parent::__construct('data://application/octet-stream;base64,' . base64_encode($data), $mime, $postname); |
|
| 24 | 24 | } |
| 25 | 25 | |
| 26 | 26 | public function __set(string $name, $value): void |
@@ -32,10 +32,10 @@ discard block |
||
| 32 | 32 | } |
| 33 | 33 | |
| 34 | 34 | if (is_object($value) ? !method_exists($value, '__toString') : !is_scalar($value)) { |
| 35 | - throw new TypeError('Cannot assign '.gettype($value).' to property CURLStringFile::$data of type string'); |
|
| 35 | + throw new TypeError('Cannot assign ' . gettype($value) . ' to property CURLStringFile::$data of type string'); |
|
| 36 | 36 | } |
| 37 | 37 | |
| 38 | - $this->name = 'data://application/octet-stream;base64,'.base64_encode($value); |
|
| 38 | + $this->name = 'data://application/octet-stream;base64,' . base64_encode($value); |
|
| 39 | 39 | } |
| 40 | 40 | |
| 41 | 41 | public function __isset(string $name): bool |