Sends an iterator of requests concurrently using a capped pool size.
The pool will read from an iterator until it is cancelled or until the
iterator is consumed. When a request is yielded, the request is sent after
applying the "request_options" request options (if provided in the ctor).
When a function is yielded by the iterator, the function is provided the
"request_options" array that should be merged on top of any existing
options, and the function MUST then return a wait-able promise.
| Implements | GuzzleHttp\Promise\PromisorInterface |
| Methods |
| public __construct(GuzzleHttp\ClientInterface $client, $requests, array $config = []) |
| public static batch(GuzzleHttp\ClientInterface $client, $requests, array $options = []) : array Sends multiple requests concurrently and returns an array of responses IMPORTANT: This method keeps every request and response in memory, and
|
| public promise() : GuzzleHttp\Promise\PromiseInterface Get promise |
| Properties |
private $each
|
| Methods |
| private static cmpCallback(array $options, string $name, array $results) : void Execute callback(s) |
| Methods |
| public static batch(GuzzleHttp\ClientInterface $client, $requests, array $options = []) : array Sends multiple requests concurrently and returns an array of responses IMPORTANT: This method keeps every request and response in memory, and
|
| private static cmpCallback(array $options, string $name, array $results) : void Execute callback(s) |