WIP: Add support for streaming requests

aiohttp_client_cache/response.py

@@ -1,8 +1,12 @@
+# TODO: CachedResponse may be better as a non-slotted subclass of ClientResponse.
+#     Will look into this when working on issue #67.
+import asyncio
 import json
 from datetime import datetime
 from http.cookies import SimpleCookie
 from logging import getLogger
 from typing import Any, Dict, Iterable, List, Mapping, Optional, Tuple, Union
+from unittest.mock import Mock
 
 import attr
 from aiohttp import ClientResponse, ClientResponseError, hdrs, multipart
@@ -94,6 +98,10 @@ async def from_client_response(cls, client_response: ClientResponse, expires: da
             )
         return response
 
+    @property
+    def content(self) -> StreamReader:
+        return CachedStreamReader(self._body)
+
     @property
     def content_disposition(self) -> Optional[ContentDisposition]:
         """Get Content-Disposition headers, if any"""
@@ -214,6 +222,19 @@ async def terminate(self):
         pass
 
 
+class CachedStreamReader(StreamReader):
+    """A StreamReader loaded from previously consumed response content. This feeds cached data into
+    the stream so it can support all the same behavior as the original stream: async iteration,
+    chunked reads, etc.
+    """
+
+    def __init__(self, body: bytes):
+        protocol = Mock(_reading_paused=False)
+        super().__init__(protocol, limit=len(body), loop=asyncio.get_event_loop())
+        self.feed_data(body)
+        self.feed_eof()
+
+
 AnyResponse = Union[ClientResponse, CachedResponse]