Rewind stream retrieved from the cache

Author: theofidry

src/CachePlugin.php

@@ -9,6 +9,7 @@
 use Psr\Cache\CacheItemPoolInterface;
 use Psr\Http\Message\RequestInterface;
 use Psr\Http\Message\ResponseInterface;
+use RewindStreamException;
 use Symfony\Component\OptionsResolver\Options;
 use Symfony\Component\OptionsResolver\OptionsResolver;
 
@@ -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/RewindStreamException.php

@@ -0,0 +1,13 @@
+<?php
+
+declare(strict_types=1);
+
+use Http\Client\Exception;
+
+/**
+ * @author Théo FIDRY <theo.fidry@gmail.com>
+ */
+class RewindStreamException extends \RuntimeException implements Exception
+{
+
+}