Add implementation

Author: ddeboer

src/Guzzle6HttpAdapter.php

@@ -0,0 +1,83 @@
+<?php
+
+namespace Http\Adapter;
+
+use FOS\HttpCache\Exception\ProxyUnreachableException;
+use GuzzleHttp\Client;
+use GuzzleHttp\Exception\RequestException;
+use GuzzleHttp\Exception\TransferException;
+use GuzzleHttp\Pool;
+use GuzzleHttp\Promise\Promise;
+use Http\Adapter\Common\Exception\HttpAdapterException;
+use Http\Adapter\Common\Exception\MultiHttpAdapterException;
+use Psr\Http\Message\RequestInterface;
+use Psr\Http\Message\ResponseInterface;
+
+class Guzzle6HttpAdapter implements PsrHttpAdapter
+{
+    public function __construct(Client $client = null)
+    {
+        $this->client = $client ?: new Client();
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function sendRequest(RequestInterface $request)
+    {
+        try {
+            return $this->client->send($request);
+        } catch (TransferException $e) {
+            throw ProxyUnreachableException::proxyUnreachable($request, $e);
+        }
+    }
+
+    /**
+     * Sends PSR requests
+     *
+     * @param RequestInterface[] $requests
+     *
+     * @return ResponseInterface[]
+     *
+     * @throws \InvalidArgumentException
+     * @throws Exception\MultiHttpAdapterException
+     */
+    public function sendRequests(array $requests)
+    {
+        $results = Pool::batch(
+            $this->client,
+            $requests
+        );
+
+        $exceptions = [];
+        foreach ($results as $result) {
+            if ($result instanceof RequestException) {
+                $exception = new HttpAdapterException(
+                    $result->getMessage(),
+                    0,
+                    $result
+                );
+                $exception->setResponse($result->getResponse());
+                $exception->setRequest($result->getRequest());
+
+                $exceptions[] = $exception;
+            }
+        }
+
+        if (count($exceptions) > 0) {
+            throw new MultiHttpAdapterException($exceptions);
+        }
+
+        return $results;
+    }
+
+    /**
+     * Returns the name
+     *
+     * @return string
+     */
+    public function getName()
+    {
+        return 'guzzle6';
+    }
+}