@@ -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) { |
@@ -52,6 +52,9 @@ discard block |
||
52 | 52 | $this->trigger($value); |
53 | 53 | } |
54 | 54 | |
55 | + /** |
|
56 | + * @param \Exception $reason |
|
57 | + */ |
|
55 | 58 | public function reject($reason) |
56 | 59 | { |
57 | 60 | $this->setState(self::STATE_REJECTED); |
@@ -110,6 +113,9 @@ discard block |
||
110 | 113 | } |
111 | 114 | } |
112 | 115 | |
116 | + /** |
|
117 | + * @param integer $index |
|
118 | + */ |
|
113 | 119 | private static function invokeContext($context, $index, $value) |
114 | 120 | { |
115 | 121 | $promise = $context[0]; |
@@ -131,6 +137,9 @@ discard block |
||
131 | 137 | } |
132 | 138 | } |
133 | 139 | |
140 | + /** |
|
141 | + * @param integer $state |
|
142 | + */ |
|
134 | 143 | private function setState($state) |
135 | 144 | { |
136 | 145 | if ($state !== self::STATE_PENDING && |
@@ -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 | } |
@@ -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)); |
@@ -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)); |