Implements options

Author: sagikazarmark

src/Guzzle6HttpAdapter.php

@@ -37,10 +37,12 @@ public function __construct(Client $client = null)
     /**
      * {@inheritdoc}
      */
-    public function sendRequest(RequestInterface $request)
+    public function sendRequest(RequestInterface $request, array $options = [])
     {
+        $options = $this->buildOptions($options);
+
         try {
-            return $this->client->send($request);
+            return $this->client->send($request, $options);
         } catch (RequestException $exception) {
             throw $this->createException($exception);
         }
@@ -49,11 +51,14 @@ public function sendRequest(RequestInterface $request)
     /**
      * {@inheritdoc}
      */
-    public function sendRequests(array $requests)
+    public function sendRequests(array $requests, array $options = [])
     {
+        $options = $this->buildOptions($options);
+
         $results = Pool::batch(
             $this->client,
-            $requests
+            $requests,
+            $options
         );
 
         $exceptions = [];
@@ -101,4 +106,23 @@ private function createException(RequestException $exception)
 
         return $adapterException;
     }
+
+    /**
+     * Builds options for Guzzle
+     *
+     * @param array $options
+     *
+     * @return array
+     */
+    private function buildOptions(array $options)
+    {
+        $guzzleOptions = [];
+
+        if (isset($options['timeout'])) {
+            $guzzleOptions['connect_timeout'] = $options['timeout'];
+            $guzzleOptions['timeout'] = $options['timeout'];
+        }
+
+        return $guzzleOptions;
+    }
 }