WireHttpMulti

getMulti($requests, $concurrency = null)

Fetch multiple URLs concurrently. Mirrors WireHttp::get() but operates on an array of URLs. Returns an array keyed by the same keys as $requests, where each value is the response body string, true for successful downloads, or false on failure.

This method saves and restores the queue and concurrency state around its execution, so it is safe to call even if requests have already been enqueued via enqueue().

Because the return value mixes strings and bools, use strict comparison (=== false, === true) when checking results rather than truthiness.

• $requests array — Associative or indexed array of URL strings or WireHttpRequestSpec objects.
• $concurrency int|null — Max concurrent requests for this call only. Defaults to the value set by setConcurrency() (default 5).

$http = new WireHttpMulti();

// Indexed array — results keyed 0, 1, 2
$bodies = $http->getMulti([
    'https://api.example.com/a',
    'https://api.example.com/b',
    'https://api.example.com/c',
]);

// Associative array — results keyed by name
$bodies = $http->getMulti([
    'alpha' => 'https://api.example.com/a',
    'beta'  => 'https://api.example.com/b',
]);
echo $bodies['alpha']; // response body or false

// WireHttpRequestSpec objects allow per-request options
$bodies = $http->getMulti([
    WireHttpRequestSpec::get('https://api.example.com/a', [CURLOPT_TIMEOUT => 10]),
    WireHttpRequestSpec::get('https://api.example.com/b'),
]);

getJSONMulti($requests, $concurrency = null)

Fetch multiple URLs concurrently and json_decode() each response. Mirrors WireHttp::getJSON() but operates on an array of URLs. Returns an array keyed by the same keys as $requests, where each value is an associative array or false on failure or invalid JSON.

Like getMulti(), this method saves and restores queue and concurrency state, so it is safe to call alongside enqueued requests.

$http = new WireHttpMulti();
$data = $http->getJSONMulti([
    'users' => 'https://api.example.com/users',
    'posts' => 'https://api.example.com/posts',
]);
if(is_array($data['users'])) {
    foreach($data['users'] as $user) echo $user['name'];
}

Use enqueue() and execute() when you need mixed request types (GET, POST, download) or want full access to result details like HTTP codes, headers, and curl errors.

enqueue($item)

Add a request to the queue. Accepts a URL string (treated as GET) or a WireHttpRequestSpec object for full control over method, body, and options. Returns $this for chaining.

$http = new WireHttpMulti();

// Simple URL string (GET)
$http->enqueue('https://api.example.com/data');

// Using WireHttpRequestSpec for more control
$http->enqueue(WireHttpRequestSpec::get('https://api.example.com/data'));
$http->enqueue(WireHttpRequestSpec::post('https://api.example.com/submit', ['key' => 'value']));
$http->enqueue(WireHttpRequestSpec::download('https://example.com/file.zip', '/path/to/file.zip'));

$results = $http->execute();

execute()

Execute all queued requests concurrently. Clears the queue and returns an array of WireHttpRequestResult objects in the same order as the requests were enqueued. Also populates the inherited getError() and getHttpCode() state from any failures.

$http = new WireHttpMulti();
$http->enqueue('https://api.example.com/a');
$http->enqueue('https://api.example.com/b');

$results = $http->execute();

foreach($results as $result) {
    if($result->success) {
        echo $result->url . ': ' . strlen($result->body) . " bytes\n";
    } else {
        echo $result->url . ' failed: ' . $result->curlError . "\n";
    }
}

setConcurrency($n)

Set the maximum number of requests to run simultaneously. Default is 5. Returns $this for chaining.

$http = new WireHttpMulti();
$http->setConcurrency(10);

setSslVerify($verify)

Set whether SSL certificates are verified. Defaults to true. Set to false to disable verification (useful for development environments with self-signed certs). Returns $this for chaining.

$http->setSslVerify(false);

setDebug($debug)

Enable or disable debug logging via Wire::log(). When enabled, logs enqueued URLs and active/queued counts during execution. Returns $this for chaining.

$http->setDebug(true);

Value object for defining a single queued request. Use the static factory methods rather than instantiating directly.

WireHttpRequestSpec::get($url, $options = null)

Create a GET request spec.

• $url string — Request URL.
• $options array|null — Per-request cURL option overrides (keyed by CURLOPT_* constant).

$spec = WireHttpRequestSpec::get('https://api.example.com/data');
$spec = WireHttpRequestSpec::get('https://api.example.com/data', [CURLOPT_TIMEOUT => 30]);

WireHttpRequestSpec::post($url, $postFields, $options = null)

Create a POST request spec with form fields.

• $url string — Request URL.
• $postFields array — Associative array of POST fields.
• $options array|null — Per-request cURL option overrides.

$spec = WireHttpRequestSpec::post('https://api.example.com/submit', [
    'name'  => 'John',
    'email' => 'john@example.com',
]);

To POST a raw JSON body instead, set $spec->body after creation:

$spec = WireHttpRequestSpec::post('https://api.example.com/submit', []);
$spec->body = json_encode(['name' => 'John']);
// Content-Type: application/json is set automatically when body is non-null

WireHttpRequestSpec::download($url, $toFile, $options = null)

Create a file download request spec.

• $url string — URL to download from.
• $toFile string — Absolute path to save the file to.
• $options array|null — Per-request cURL option overrides.

$spec = WireHttpRequestSpec::download(
    'https://example.com/file.zip',
    $config->paths->files . 'file.zip'
);

WireHttpRequestSpec properties

Immutable result object returned by execute(). All properties are read-only.

toArray()

Return all result properties as an associative array.

$result = $http->execute()[0];
$arr = $result->toArray();
// ['url' => ..., 'method' => ..., 'success' => ..., ...]