Rewind stream when possible (#29)

* Rewind stream retrieved from the cache

* Move exception to Common namespace

* move exception

* reverted

Author: theofidry

src/CachePlugin.php

@@ -3,6 +3,7 @@
 namespace Http\Client\Common\Plugin;
 
 use Http\Client\Common\Plugin;
+use Http\Client\Common\Plugin\Exception\RewindStreamException;
 use Http\Message\StreamFactory;
 use Http\Promise\FulfilledPromise;
 use Psr\Cache\CacheItemInterface;
@@ -379,7 +380,15 @@ private function createResponseFromCacheItem(CacheItemInterface $cacheItem)
 
         /** @var ResponseInterface $response */
         $response = $data['response'];
-        $response = $response->withBody($this->streamFactory->createStream($data['body']));
+        $stream = $this->streamFactory->createStream($data['body']);
+
+        try {
+            $stream->rewind();
+        } catch (\Exception $e) {
+            throw new RewindStreamException('Cannot rewind stream.', 0, $e);
+        }
+
+        $response = $response->withBody($stream);
 
         return $response;
     }

src/Exception/RewindStreamException.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace Http\Client\Common\Plugin\Exception;
+
+use Http\Client\Exception;
+
+/**
+ * @author Théo FIDRY <theo.fidry@gmail.com>
+ */
+class RewindStreamException extends \RuntimeException implements Exception
+{
+}