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\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) |