@@ -87,7 +87,7 @@ discard block |
||
| 87 | 87 | private function createPromise() |
| 88 | 88 | { |
| 89 | 89 | $this->mutex = false; |
| 90 | - $this->aggregate = new Promise(function () { |
|
| 90 | + $this->aggregate = new Promise(function() { |
|
| 91 | 91 | reset($this->pending); |
| 92 | 92 | if (empty($this->pending) && !$this->iterable->valid()) { |
| 93 | 93 | $this->aggregate->resolve(null); |
@@ -106,7 +106,7 @@ discard block |
||
| 106 | 106 | }); |
| 107 | 107 | |
| 108 | 108 | // Clear the references when the promise is resolved. |
| 109 | - $clearFn = function () { |
|
| 109 | + $clearFn = function() { |
|
| 110 | 110 | $this->iterable = $this->concurrency = $this->pending = null; |
| 111 | 111 | $this->onFulfilled = $this->onRejected = null; |
| 112 | 112 | }; |
@@ -152,7 +152,7 @@ discard block |
||
| 152 | 152 | $idx = $this->iterable->key(); |
| 153 | 153 | |
| 154 | 154 | $this->pending[$idx] = $promise->then( |
| 155 | - function ($value) use ($idx) { |
|
| 155 | + function($value) use ($idx) { |
|
| 156 | 156 | if ($this->onFulfilled) { |
| 157 | 157 | call_user_func( |
| 158 | 158 | $this->onFulfilled, $value, $idx, $this->aggregate |
@@ -160,7 +160,7 @@ discard block |
||
| 160 | 160 | } |
| 161 | 161 | $this->step($idx); |
| 162 | 162 | }, |
| 163 | - function ($reason) use ($idx) { |
|
| 163 | + function($reason) use ($idx) { |
|
| 164 | 164 | if ($this->onRejected) { |
| 165 | 165 | call_user_func( |
| 166 | 166 | $this->onRejected, $reason, $idx, $this->aggregate |