Non-blocking http requests in PHP

source.php

<?php

final class PricesHttpClient implements PricesClient
{
    public function __construct(
        // AMPHP http client (https://github.com/amphp/http-client)
        private HttpClient $httpClient,
    ) {
    }

    /**
     * @param list<string> $productIds
     *
     * @return Price[]
     */
    public function getPrices(array $productIds): array
    {
        $response = $this->httpClient->request('GET', '/api/prices', [
            'query' => [
                'productIds' => implode(',', $productIds),
            ],
        ]);

        $pricesArray = $response->getJsonArray();

        return array_map(static fn ($unit) => Price::fromUnit($unit), $pricesArray);
    }
}

final class PricesConcurrentClient implements PricesClient
{
    public function __construct(
        #[AutowireDecorated]
        private PricesClient $client,
    ) {
    }

    /**
     * @param list<string> $productIds
     *
     * @return Price[]
     */
    public function getPrices(array $productIds): array
    {
        $chunks = array_chunk($productIds, 100);

        $promises = [];

        foreach ($chunks as $chunk) {
            $promises [] = async(fn () => $this->client->getPrices($chunk));
        }

        /** @var Price[][] $prices */
        $prices = await($promises);

        return array_merge(...$prices);
    }
}

$pricesClient = new PricesConcurrentClient(new PricesHttpClient($amphpHttpClient));

// async/await logic is hidden inside

$prices = $pricesClient->getPrices($productIds);