12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061 |
- <?php
- namespace Http\Client\Common;
- use Http\Client\Common\Exception\HttpClientNotFoundException;
- use Http\Client\HttpAsyncClient;
- use Http\Client\HttpClient;
- use Psr\Http\Client\ClientInterface;
- use Psr\Http\Message\RequestInterface;
- /**
- * A http client pool allows to send requests on a pool of different http client using a specific strategy (least used,
- * round robin, ...).
- */
- abstract class HttpClientPool implements HttpAsyncClient, HttpClient
- {
- /**
- * @var HttpClientPoolItem[]
- */
- protected $clientPool = [];
- /**
- * Add a client to the pool.
- *
- * @param HttpClient|HttpAsyncClient|HttpClientPoolItem|ClientInterface $client
- */
- public function addHttpClient($client)
- {
- if (!$client instanceof HttpClientPoolItem) {
- $client = new HttpClientPoolItem($client);
- }
- $this->clientPool[] = $client;
- }
- /**
- * Return an http client given a specific strategy.
- *
- * @throws HttpClientNotFoundException When no http client has been found into the pool
- *
- * @return HttpClientPoolItem Return a http client that can do both sync or async
- */
- abstract protected function chooseHttpClient();
- /**
- * {@inheritdoc}
- */
- public function sendAsyncRequest(RequestInterface $request)
- {
- return $this->chooseHttpClient()->sendAsyncRequest($request);
- }
- /**
- * {@inheritdoc}
- */
- public function sendRequest(RequestInterface $request)
- {
- return $this->chooseHttpClient()->sendRequest($request);
- }
- }
|