@@ -23,6 +23,9 @@ |
||
| 23 | 23 | return new static; |
| 24 | 24 | } |
| 25 | 25 | |
| 26 | + /** |
|
| 27 | + * @param \Closure $handler |
|
| 28 | + */ |
|
| 26 | 29 | public function store($handler, $value = []) |
| 27 | 30 | { |
| 28 | 31 | if ($handler instanceof \Closure) { |
@@ -31,7 +31,7 @@ |
||
| 31 | 31 | $q = new Promise(); |
| 32 | 32 | $value = $this->value; |
| 33 | 33 | |
| 34 | - Context\ContextStack::create(new TaskQueue)->store(static function () use ($q, $value, $onFulfilled) { |
|
| 34 | + Context\ContextStack::create(new TaskQueue)->store(static function() use ($q, $value, $onFulfilled) { |
|
| 35 | 35 | if ($q->currentState() === self::STATE_PENDING) { |
| 36 | 36 | try { |
| 37 | 37 | $q->resolve($onFulfilled($value)); |
@@ -85,7 +85,7 @@ discard block |
||
| 85 | 85 | $index = $this->state === self::STATE_FULFILLED ? 1 : 2; |
| 86 | 86 | |
| 87 | 87 | Context\ContextStack::create(new TaskQueue)->store( |
| 88 | - static function () use ($index, $context, $value) { |
|
| 88 | + static function() use ($index, $context, $value) { |
|
| 89 | 89 | foreach ($context as $c) { |
| 90 | 90 | self::invokeContext($c, $index, $value); |
| 91 | 91 | } |
@@ -96,12 +96,12 @@ discard block |
||
| 96 | 96 | $value->context = array_merge($value->context, $context); |
| 97 | 97 | } else { |
| 98 | 98 | $value->then( |
| 99 | - static function ($value) use ($context) { |
|
| 99 | + static function($value) use ($context) { |
|
| 100 | 100 | foreach ($context as $c) { |
| 101 | 101 | self::invokeContext($c, 1, $value); |
| 102 | 102 | } |
| 103 | 103 | }, |
| 104 | - static function ($reason) use ($context) { |
|
| 104 | + static function($reason) use ($context) { |
|
| 105 | 105 | foreach ($context as $c) { |
| 106 | 106 | self::invokeContext($c, 2, $reason); |
| 107 | 107 | } |
@@ -78,6 +78,9 @@ discard block |
||
| 78 | 78 | $this->cancelCallback = $callback; |
| 79 | 79 | } |
| 80 | 80 | |
| 81 | + /** |
|
| 82 | + * @param integer $state |
|
| 83 | + */ |
|
| 81 | 84 | private function validateState($value, $state) |
| 82 | 85 | { |
| 83 | 86 | if ($this->state !== self::STATE_PENDING) { |
@@ -273,6 +276,9 @@ discard block |
||
| 273 | 276 | } |
| 274 | 277 | } |
| 275 | 278 | |
| 279 | + /** |
|
| 280 | + * @param integer $index |
|
| 281 | + */ |
|
| 276 | 282 | private static function invokeContext($context, $index, $value) |
| 277 | 283 | { |
| 278 | 284 | $promise = $context[0]; |
@@ -294,6 +300,9 @@ discard block |
||
| 294 | 300 | } |
| 295 | 301 | } |
| 296 | 302 | |
| 303 | + /** |
|
| 304 | + * @param integer $state |
|
| 305 | + */ |
|
| 297 | 306 | private function setState($state) |
| 298 | 307 | { |
| 299 | 308 | if ($state !== self::STATE_PENDING && |
@@ -31,7 +31,7 @@ |
||
| 31 | 31 | $q = new Promise(); |
| 32 | 32 | $reason = $this->reason; |
| 33 | 33 | |
| 34 | - Context\ContextStack::create(new TaskQueue)->store(static function () use ($q, $reason, $onRejected) { |
|
| 34 | + Context\ContextStack::create(new TaskQueue)->store(static function() use ($q, $reason, $onRejected) { |
|
| 35 | 35 | if ($q->currentState() === self::STATE_PENDING) { |
| 36 | 36 | try { |
| 37 | 37 | $q->resolve($onRejected($reason)); |