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 IMPORTANT: This method keeps every request and response in memory, and
|
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 IMPORTANT: This method keeps every request and response in memory, and
|
private static cmpCallback(array $options, string $name, array $results) : void Execute callback(s) |