@@ 402-408 (lines=7) @@ | ||
399 | ||
400 | $pool = new Pool($this->client, $generator, [ |
|
401 | 'concurrency' => getenv('MAX_CONNECTIONS'), |
|
402 | 'fulfilled' => function ($response, $name) { |
|
403 | $gzip = (string) $response->getBody(); |
|
404 | file_put_contents($name, $this->parseGzip($gzip)); |
|
405 | $this->createLink($name); |
|
406 | $this->packages[] = dirname($name); |
|
407 | $this->progressBarUpdate(); |
|
408 | }, |
|
409 | 'rejected' => function ($reason, $name) { |
|
410 | $this->errors[$name] = $reason; |
|
411 | $this->progressBarUpdate(); |
|
@@ 477-483 (lines=7) @@ | ||
474 | ||
475 | $pool = new Pool($this->client, $generator, [ |
|
476 | 'concurrency' => getenv('MAX_CONNECTIONS') * $this->circular->count(), |
|
477 | 'fulfilled' => function ($response, $name) { |
|
478 | $gzip = (string) $response->getBody(); |
|
479 | file_put_contents($name, $this->parseGzip($gzip)); |
|
480 | $this->createLink($name); |
|
481 | $this->packages[] = dirname($name); |
|
482 | $this->progressBarUpdate(); |
|
483 | }, |
|
484 | 'rejected' => function ($reason, $name) { |
|
485 | $this->errors[$name] = $reason; |
|
486 | $this->progressBarUpdate(); |