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