@@ -1,7 +1,6 @@ |
||
1 | 1 | <?php |
2 | 2 | |
3 | 3 | namespace mpyw\Co\Internal; |
4 | -use React\Promise\Deferred; |
|
5 | 4 | use mpyw\Co\AllFailedException; |
6 | 5 | use mpyw\Co\CoInterface; |
7 | 6 |
@@ -73,7 +73,7 @@ discard block |
||
73 | 73 | */ |
74 | 74 | public static function getApplier($yielded, array $yieldables, callable $next = null) |
75 | 75 | { |
76 | - return function (array $results) use ($yielded, $yieldables, $next) { |
|
76 | + return function(array $results) use ($yielded, $yieldables, $next) { |
|
77 | 77 | foreach ($results as $hash => $resolved) { |
78 | 78 | $current = &$yielded; |
79 | 79 | foreach ($yieldables[$hash]['keylist'] as $key) { |
@@ -93,7 +93,7 @@ discard block |
||
93 | 93 | */ |
94 | 94 | public static function safePromise(PromiseInterface $promise) |
95 | 95 | { |
96 | - return $promise->then(null, function ($value) { |
|
96 | + return $promise->then(null, function($value) { |
|
97 | 97 | if (TypeUtils::isFatalThrowable($value)) { |
98 | 98 | throw $value; |
99 | 99 | } |
@@ -164,7 +164,7 @@ discard block |
||
164 | 164 | YieldableUtils::getApplier($returned, $yieldables, [$deferred, 'resolve']), |
165 | 165 | [$deferred, 'reject'] |
166 | 166 | ) |
167 | - ->then(function () use ($yieldables, $deferred) { |
|
167 | + ->then(function() use ($yieldables, $deferred) { |
|
168 | 168 | $this->runners = array_diff_key($this->runners, $yieldables); |
169 | 169 | return $deferred->promise(); |
170 | 170 | }); |
@@ -184,7 +184,7 @@ discard block |
||
184 | 184 | // Check delay request yields |
185 | 185 | if ($gc->key() === CoInterface::DELAY) { |
186 | 186 | return $this->pool->addDelay($gc->current()) |
187 | - ->then(function () use ($gc) { |
|
187 | + ->then(function() use ($gc) { |
|
188 | 188 | $gc->send(null); |
189 | 189 | return $this->processGeneratorContainer($gc); |
190 | 190 | }); |
@@ -205,7 +205,7 @@ discard block |
||
205 | 205 | ->then( |
206 | 206 | YieldableUtils::getApplier($yielded, $yieldables, [$gc, 'send']), |
207 | 207 | [$gc, 'throw_'] |
208 | - )->then(function () use ($gc, $yieldables) { |
|
208 | + )->then(function() use ($gc, $yieldables) { |
|
209 | 209 | // Continue |
210 | 210 | $this->runners = array_diff_key($this->runners, $yieldables); |
211 | 211 | return $this->processGeneratorContainer($gc); |