@@ -197,7 +197,7 @@ |
||
| 197 | 197 | // Ensure we do not exceed maximum integer size, which may |
| 198 | 198 | // cause the loop to tick once every ~35min on 32bit systems. |
| 199 | 199 | $timeout *= self::MICROSECONDS_PER_SECOND; |
| 200 | - $timeout = $timeout > \PHP_INT_MAX ? \PHP_INT_MAX : (int)$timeout; |
|
| 200 | + $timeout = $timeout > \PHP_INT_MAX ? \PHP_INT_MAX : (int) $timeout; |
|
| 201 | 201 | } |
| 202 | 202 | |
| 203 | 203 | // The only possible event is stream or signal activity, so wait forever ... |
@@ -31,7 +31,7 @@ discard block |
||
| 31 | 31 | $canceller = [$promiseOrValue, 'cancel']; |
| 32 | 32 | } |
| 33 | 33 | |
| 34 | - return new Promise(function ($resolve, $reject, $notify) use ($promiseOrValue) { |
|
| 34 | + return new Promise(function($resolve, $reject, $notify) use ($promiseOrValue) { |
|
| 35 | 35 | $promiseOrValue->then($resolve, $reject, $notify); |
| 36 | 36 | }, $canceller); |
| 37 | 37 | } |
@@ -58,7 +58,7 @@ discard block |
||
| 58 | 58 | function reject($promiseOrValue = null) |
| 59 | 59 | { |
| 60 | 60 | if ($promiseOrValue instanceof PromiseInterface) { |
| 61 | - return resolve($promiseOrValue)->then(function ($value) { |
|
| 61 | + return resolve($promiseOrValue)->then(function($value) { |
|
| 62 | 62 | return new RejectedPromise($value); |
| 63 | 63 | }); |
| 64 | 64 | } |
@@ -77,7 +77,7 @@ discard block |
||
| 77 | 77 | */ |
| 78 | 78 | function all($promisesOrValues) |
| 79 | 79 | { |
| 80 | - return map($promisesOrValues, function ($val) { |
|
| 80 | + return map($promisesOrValues, function($val) { |
|
| 81 | 81 | return $val; |
| 82 | 82 | }); |
| 83 | 83 | } |
@@ -97,9 +97,9 @@ discard block |
||
| 97 | 97 | $cancellationQueue = new CancellationQueue(); |
| 98 | 98 | $cancellationQueue->enqueue($promisesOrValues); |
| 99 | 99 | |
| 100 | - return new Promise(function ($resolve, $reject, $notify) use ($promisesOrValues, $cancellationQueue) { |
|
| 100 | + return new Promise(function($resolve, $reject, $notify) use ($promisesOrValues, $cancellationQueue) { |
|
| 101 | 101 | resolve($promisesOrValues) |
| 102 | - ->done(function ($array) use ($cancellationQueue, $resolve, $reject, $notify) { |
|
| 102 | + ->done(function($array) use ($cancellationQueue, $resolve, $reject, $notify) { |
|
| 103 | 103 | if (!is_array($array) || !$array) { |
| 104 | 104 | $resolve(); |
| 105 | 105 | return; |
@@ -132,7 +132,7 @@ discard block |
||
| 132 | 132 | function any($promisesOrValues) |
| 133 | 133 | { |
| 134 | 134 | return some($promisesOrValues, 1) |
| 135 | - ->then(function ($val) { |
|
| 135 | + ->then(function($val) { |
|
| 136 | 136 | return \array_shift($val); |
| 137 | 137 | }); |
| 138 | 138 | } |
@@ -160,9 +160,9 @@ discard block |
||
| 160 | 160 | $cancellationQueue = new CancellationQueue(); |
| 161 | 161 | $cancellationQueue->enqueue($promisesOrValues); |
| 162 | 162 | |
| 163 | - return new Promise(function ($resolve, $reject, $notify) use ($promisesOrValues, $howMany, $cancellationQueue) { |
|
| 163 | + return new Promise(function($resolve, $reject, $notify) use ($promisesOrValues, $howMany, $cancellationQueue) { |
|
| 164 | 164 | resolve($promisesOrValues) |
| 165 | - ->done(function ($array) use ($howMany, $cancellationQueue, $resolve, $reject, $notify) { |
|
| 165 | + ->done(function($array) use ($howMany, $cancellationQueue, $resolve, $reject, $notify) { |
|
| 166 | 166 | if (!\is_array($array) || $howMany < 1) { |
| 167 | 167 | $resolve([]); |
| 168 | 168 | return; |
@@ -188,7 +188,7 @@ discard block |
||
| 188 | 188 | $reasons = []; |
| 189 | 189 | |
| 190 | 190 | foreach ($array as $i => $promiseOrValue) { |
| 191 | - $fulfiller = function ($val) use ($i, &$values, &$toResolve, $toReject, $resolve) { |
|
| 191 | + $fulfiller = function($val) use ($i, &$values, &$toResolve, $toReject, $resolve) { |
|
| 192 | 192 | if ($toResolve < 1 || $toReject < 1) { |
| 193 | 193 | return; |
| 194 | 194 | } |
@@ -200,7 +200,7 @@ discard block |
||
| 200 | 200 | } |
| 201 | 201 | }; |
| 202 | 202 | |
| 203 | - $rejecter = function ($reason) use ($i, &$reasons, &$toReject, $toResolve, $reject) { |
|
| 203 | + $rejecter = function($reason) use ($i, &$reasons, &$toReject, $toResolve, $reject) { |
|
| 204 | 204 | if ($toResolve < 1 || $toReject < 1) { |
| 205 | 205 | return; |
| 206 | 206 | } |
@@ -237,9 +237,9 @@ discard block |
||
| 237 | 237 | $cancellationQueue = new CancellationQueue(); |
| 238 | 238 | $cancellationQueue->enqueue($promisesOrValues); |
| 239 | 239 | |
| 240 | - return new Promise(function ($resolve, $reject, $notify) use ($promisesOrValues, $mapFunc, $cancellationQueue) { |
|
| 240 | + return new Promise(function($resolve, $reject, $notify) use ($promisesOrValues, $mapFunc, $cancellationQueue) { |
|
| 241 | 241 | resolve($promisesOrValues) |
| 242 | - ->done(function ($array) use ($mapFunc, $cancellationQueue, $resolve, $reject, $notify) { |
|
| 242 | + ->done(function($array) use ($mapFunc, $cancellationQueue, $resolve, $reject, $notify) { |
|
| 243 | 243 | if (!\is_array($array) || !$array) { |
| 244 | 244 | $resolve([]); |
| 245 | 245 | return; |
@@ -255,7 +255,7 @@ discard block |
||
| 255 | 255 | resolve($promiseOrValue) |
| 256 | 256 | ->then($mapFunc) |
| 257 | 257 | ->done( |
| 258 | - function ($mapped) use ($i, &$values, &$toResolve, $resolve) { |
|
| 258 | + function($mapped) use ($i, &$values, &$toResolve, $resolve) { |
|
| 259 | 259 | $values[$i] = $mapped; |
| 260 | 260 | |
| 261 | 261 | if (0 === --$toResolve) { |
@@ -286,9 +286,9 @@ discard block |
||
| 286 | 286 | $cancellationQueue = new CancellationQueue(); |
| 287 | 287 | $cancellationQueue->enqueue($promisesOrValues); |
| 288 | 288 | |
| 289 | - return new Promise(function ($resolve, $reject, $notify) use ($promisesOrValues, $reduceFunc, $initialValue, $cancellationQueue) { |
|
| 289 | + return new Promise(function($resolve, $reject, $notify) use ($promisesOrValues, $reduceFunc, $initialValue, $cancellationQueue) { |
|
| 290 | 290 | resolve($promisesOrValues) |
| 291 | - ->done(function ($array) use ($reduceFunc, $initialValue, $cancellationQueue, $resolve, $reject, $notify) { |
|
| 291 | + ->done(function($array) use ($reduceFunc, $initialValue, $cancellationQueue, $resolve, $reject, $notify) { |
|
| 292 | 292 | if (!\is_array($array)) { |
| 293 | 293 | $array = []; |
| 294 | 294 | } |
@@ -298,13 +298,13 @@ discard block |
||
| 298 | 298 | |
| 299 | 299 | // Wrap the supplied $reduceFunc with one that handles promises and then |
| 300 | 300 | // delegates to the supplied. |
| 301 | - $wrappedReduceFunc = function ($current, $val) use ($reduceFunc, $cancellationQueue, $total, &$i) { |
|
| 301 | + $wrappedReduceFunc = function($current, $val) use ($reduceFunc, $cancellationQueue, $total, &$i) { |
|
| 302 | 302 | $cancellationQueue->enqueue($val); |
| 303 | 303 | |
| 304 | 304 | return $current |
| 305 | - ->then(function ($c) use ($reduceFunc, $total, &$i, $val) { |
|
| 305 | + ->then(function($c) use ($reduceFunc, $total, &$i, $val) { |
|
| 306 | 306 | return resolve($val) |
| 307 | - ->then(function ($value) use ($reduceFunc, $total, &$i, $c) { |
|
| 307 | + ->then(function($value) use ($reduceFunc, $total, &$i, $c) { |
|
| 308 | 308 | return $reduceFunc($c, $value, $i++, $total); |
| 309 | 309 | }); |
| 310 | 310 | }); |
@@ -45,7 +45,7 @@ discard block |
||
| 45 | 45 | |
| 46 | 46 | return new static( |
| 47 | 47 | $this->resolver($onFulfilled, $onRejected, $onProgress), |
| 48 | - static function () use (&$parent) { |
|
| 48 | + static function() use (&$parent) { |
|
| 49 | 49 | if (++$parent->cancelRequests >= $parent->requiredCancelRequests) { |
| 50 | 50 | $parent->cancel(); |
| 51 | 51 | } |
@@ -61,7 +61,7 @@ discard block |
||
| 61 | 61 | return $this->result->done($onFulfilled, $onRejected, $onProgress); |
| 62 | 62 | } |
| 63 | 63 | |
| 64 | - $this->handlers[] = static function (ExtendedPromiseInterface $promise) use ($onFulfilled, $onRejected) { |
|
| 64 | + $this->handlers[] = static function(ExtendedPromiseInterface $promise) use ($onFulfilled, $onRejected) { |
|
| 65 | 65 | $promise |
| 66 | 66 | ->done($onFulfilled, $onRejected); |
| 67 | 67 | }; |
@@ -73,7 +73,7 @@ discard block |
||
| 73 | 73 | |
| 74 | 74 | public function otherwise(callable $onRejected) |
| 75 | 75 | { |
| 76 | - return $this->then(null, static function ($reason) use ($onRejected) { |
|
| 76 | + return $this->then(null, static function($reason) use ($onRejected) { |
|
| 77 | 77 | if (!_checkTypehint($onRejected, $reason)) { |
| 78 | 78 | return new RejectedPromise($reason); |
| 79 | 79 | } |
@@ -84,12 +84,12 @@ discard block |
||
| 84 | 84 | |
| 85 | 85 | public function always(callable $onFulfilledOrRejected) |
| 86 | 86 | { |
| 87 | - return $this->then(static function ($value) use ($onFulfilledOrRejected) { |
|
| 88 | - return resolve($onFulfilledOrRejected())->then(function () use ($value) { |
|
| 87 | + return $this->then(static function($value) use ($onFulfilledOrRejected) { |
|
| 88 | + return resolve($onFulfilledOrRejected())->then(function() use ($value) { |
|
| 89 | 89 | return $value; |
| 90 | 90 | }); |
| 91 | - }, static function ($reason) use ($onFulfilledOrRejected) { |
|
| 92 | - return resolve($onFulfilledOrRejected())->then(function () use ($reason) { |
|
| 91 | + }, static function($reason) use ($onFulfilledOrRejected) { |
|
| 92 | + return resolve($onFulfilledOrRejected())->then(function() use ($reason) { |
|
| 93 | 93 | return new RejectedPromise($reason); |
| 94 | 94 | }); |
| 95 | 95 | }); |
@@ -114,9 +114,9 @@ discard block |
||
| 114 | 114 | |
| 115 | 115 | private function resolver(callable $onFulfilled = null, callable $onRejected = null, callable $onProgress = null) |
| 116 | 116 | { |
| 117 | - return function ($resolve, $reject, $notify) use ($onFulfilled, $onRejected, $onProgress) { |
|
| 117 | + return function($resolve, $reject, $notify) use ($onFulfilled, $onRejected, $onProgress) { |
|
| 118 | 118 | if ($onProgress) { |
| 119 | - $progressHandler = static function ($update) use ($notify, $onProgress) { |
|
| 119 | + $progressHandler = static function($update) use ($notify, $onProgress) { |
|
| 120 | 120 | try { |
| 121 | 121 | $notify($onProgress($update)); |
| 122 | 122 | } catch (\Throwable $e) { |
@@ -129,7 +129,7 @@ discard block |
||
| 129 | 129 | $progressHandler = $notify; |
| 130 | 130 | } |
| 131 | 131 | |
| 132 | - $this->handlers[] = static function (ExtendedPromiseInterface $promise) use ($onFulfilled, $onRejected, $resolve, $reject, $progressHandler) { |
|
| 132 | + $this->handlers[] = static function(ExtendedPromiseInterface $promise) use ($onFulfilled, $onRejected, $resolve, $reject, $progressHandler) { |
|
| 133 | 133 | $promise |
| 134 | 134 | ->then($onFulfilled, $onRejected) |
| 135 | 135 | ->done($resolve, $reject, $progressHandler); |
@@ -222,23 +222,23 @@ discard block |
||
| 222 | 222 | // garbage cycles if any callback creates an Exception. |
| 223 | 223 | // These assumptions are covered by the test suite, so if you ever feel like |
| 224 | 224 | // refactoring this, go ahead, any alternative suggestions are welcome! |
| 225 | - $target =& $this; |
|
| 226 | - $progressHandlers =& $this->progressHandlers; |
|
| 225 | + $target = & $this; |
|
| 226 | + $progressHandlers = & $this->progressHandlers; |
|
| 227 | 227 | |
| 228 | 228 | $callback( |
| 229 | - static function ($value = null) use (&$target) { |
|
| 229 | + static function($value = null) use (&$target) { |
|
| 230 | 230 | if ($target !== null) { |
| 231 | 231 | $target->settle(resolve($value)); |
| 232 | 232 | $target = null; |
| 233 | 233 | } |
| 234 | 234 | }, |
| 235 | - static function ($reason = null) use (&$target) { |
|
| 235 | + static function($reason = null) use (&$target) { |
|
| 236 | 236 | if ($target !== null) { |
| 237 | 237 | $target->reject($reason); |
| 238 | 238 | $target = null; |
| 239 | 239 | } |
| 240 | 240 | }, |
| 241 | - static function ($update = null) use (&$progressHandlers) { |
|
| 241 | + static function($update = null) use (&$progressHandlers) { |
|
| 242 | 242 | foreach ($progressHandlers as $handler) { |
| 243 | 243 | $handler($update); |
| 244 | 244 | } |
@@ -61,8 +61,8 @@ |
||
| 61 | 61 | |
| 62 | 62 | public function always(callable $onFulfilledOrRejected) |
| 63 | 63 | { |
| 64 | - return $this->then(null, function ($reason) use ($onFulfilledOrRejected) { |
|
| 65 | - return resolve($onFulfilledOrRejected())->then(function () use ($reason) { |
|
| 64 | + return $this->then(null, function($reason) use ($onFulfilledOrRejected) { |
|
| 65 | + return resolve($onFulfilledOrRejected())->then(function() use ($reason) { |
|
| 66 | 66 | return new RejectedPromise($reason); |
| 67 | 67 | }); |
| 68 | 68 | }); |
@@ -53,8 +53,8 @@ |
||
| 53 | 53 | |
| 54 | 54 | public function always(callable $onFulfilledOrRejected) |
| 55 | 55 | { |
| 56 | - return $this->then(function ($value) use ($onFulfilledOrRejected) { |
|
| 57 | - return resolve($onFulfilledOrRejected())->then(function () use ($value) { |
|
| 56 | + return $this->then(function($value) use ($onFulfilledOrRejected) { |
|
| 57 | + return resolve($onFulfilledOrRejected())->then(function() use ($value) { |
|
| 58 | 58 | return $value; |
| 59 | 59 | }); |
| 60 | 60 | }); |
@@ -18,7 +18,7 @@ |
||
| 18 | 18 | public function promise() |
| 19 | 19 | { |
| 20 | 20 | if (null === $this->promise) { |
| 21 | - $this->promise = new Promise(function ($resolve, $reject, $notify) { |
|
| 21 | + $this->promise = new Promise(function($resolve, $reject, $notify) { |
|
| 22 | 22 | $this->resolveCallback = $resolve; |
| 23 | 23 | $this->rejectCallback = $reject; |
| 24 | 24 | $this->notifyCallback = $notify; |
@@ -78,7 +78,7 @@ discard block |
||
| 78 | 78 | $error = \error_get_last(); |
| 79 | 79 | if (\preg_match('/\(([^\)]+)\)|\[(\d+)\]: (.*)/', $error['message'], $match)) { |
| 80 | 80 | $errstr = isset($match[3]) ? $match['3'] : $match[1]; |
| 81 | - $errno = isset($match[2]) ? (int)$match[2] : 0; |
|
| 81 | + $errno = isset($match[2]) ? (int) $match[2] : 0; |
|
| 82 | 82 | } |
| 83 | 83 | } |
| 84 | 84 | |
@@ -118,7 +118,7 @@ discard block |
||
| 118 | 118 | } |
| 119 | 119 | |
| 120 | 120 | $that = $this; |
| 121 | - $this->loop->addReadStream($this->master, function ($master) use ($that) { |
|
| 121 | + $this->loop->addReadStream($this->master, function($master) use ($that) { |
|
| 122 | 122 | try { |
| 123 | 123 | $newSocket = SocketServer::accept($master); |
| 124 | 124 | } catch (\RuntimeException $e) { |
@@ -68,10 +68,10 @@ |
||
| 68 | 68 | $this->server = $server; |
| 69 | 69 | |
| 70 | 70 | $that = $this; |
| 71 | - $server->on('connection', function (ConnectionInterface $conn) use ($that) { |
|
| 71 | + $server->on('connection', function(ConnectionInterface $conn) use ($that) { |
|
| 72 | 72 | $that->emit('connection', array($conn)); |
| 73 | 73 | }); |
| 74 | - $server->on('error', function (\Exception $error) use ($that) { |
|
| 74 | + $server->on('error', function(\Exception $error) use ($that) { |
|
| 75 | 75 | $that->emit('error', array($error)); |
| 76 | 76 | }); |
| 77 | 77 | } |
@@ -178,7 +178,7 @@ |
||
| 178 | 178 | } |
| 179 | 179 | |
| 180 | 180 | $that = $this; |
| 181 | - $this->loop->addReadStream($this->master, function ($master) use ($that) { |
|
| 181 | + $this->loop->addReadStream($this->master, function($master) use ($that) { |
|
| 182 | 182 | try { |
| 183 | 183 | $newSocket = SocketServer::accept($master); |
| 184 | 184 | } catch (\RuntimeException $e) { |