@@ -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) { |