@@ -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 | } |
@@ -251,6 +251,9 @@ discard block |
||
| 251 | 251 | } |
| 252 | 252 | } |
| 253 | 253 | |
| 254 | + /** |
|
| 255 | + * @param integer $index |
|
| 256 | + */ |
|
| 254 | 257 | private static function invokeContext($context, $index, $value) |
| 255 | 258 | { |
| 256 | 259 | $promise = $context[0]; |
@@ -272,6 +275,9 @@ discard block |
||
| 272 | 275 | } |
| 273 | 276 | } |
| 274 | 277 | |
| 278 | + /** |
|
| 279 | + * @param integer $state |
|
| 280 | + */ |
|
| 275 | 281 | private function setState($state) |
| 276 | 282 | { |
| 277 | 283 | 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)); |