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.
- final
| Methods |
public __construct(GuzzleHttp
|
| public static batch(GuzzleHttp Sends multiple requests concurrently and returns an array of responses and exceptions that uses the same ordering as the provided requests. IMPORTANT: This method keeps every request and response in memory, and as such, is NOT recommended when sending a large number or an indeterminate number of requests concurrently.
|
| public promise() : GuzzleHttp Get promise |
| Properties |
private $each = NULL
|
| Methods |
| private static cmpCallback(array $options, string $name, array $results) : void Execute callback(s) |
| Methods |
| public static batch(GuzzleHttp Sends multiple requests concurrently and returns an array of responses and exceptions that uses the same ordering as the provided requests. IMPORTANT: This method keeps every request and response in memory, and as such, is NOT recommended when sending a large number or an indeterminate number of requests concurrently.
|
| private static cmpCallback(array $options, string $name, array $results) : void Execute callback(s) |