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.

CloneableInstantiable
ImplementsGuzzleHttp\Promise\PromisorInterface
Methods
public __construct(GuzzleHttp\ClientInterface $client, $requests, array $config = [])
 
    public static batch(GuzzleHttp\ClientInterface $client, $requests, array $options = [])
     

    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.

    • return array Returns an array containing the response or an exception in the same order that the requests were sent.
    • throws InvalidArgumentException if the event format is incorrect.
    public promise()
     

    Get promise

    • return PromiseInterface
    Properties
    private $each
     
    • var EachPromise
    Methods
    private static cmpCallback(array $options, $name, array $results)
     

    Execute callback(s)

    • return void
    Methods
    public static batch(GuzzleHttp\ClientInterface $client, $requests, array $options = [])
     

    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.

    • return array Returns an array containing the response or an exception in the same order that the requests were sent.
    • throws InvalidArgumentException if the event format is incorrect.
    private static cmpCallback(array $options, $name, array $results)
     

    Execute callback(s)

    • return void
    © 2020 Bruce Wells
    Search Namespaces \ Classes
    ConfigurationNumbers (0-9.) only