Merge pull request #19 from cbrichford/streams-fix

Fixing streaming responses.

aiobotocore/endpoint.py

@@ -32,6 +32,24 @@ def convert_to_response_dict(http_response, operation_model):
     return response_dict
 
 
+class ClientResponseContentProxy:
+    """Proxy object for content stream of http response"""
+
+    def __init__(self, response):
+        self.__response = response
+        self.__content = self.__response.content
+
+    def __getattr__(self, item):
+        return getattr(self.__content, item)
+
+    def __dir__(self):
+        attrs = dir(self.__content)
+        attrs.append('close')
+        return attrs
+
+    def close(self):
+        self.__response.close()
+
 class ClientResponseProxy:
     """Proxy object for http response useful for porting from
     botocore underlying http library."""
@@ -46,7 +64,7 @@ def __getattr__(self, item):
         if item == 'content':
             return self._body
         if item == 'raw':
-            return getattr(self._impl, 'content')
+            return ClientResponseContentProxy(self._impl)
 
         return getattr(self._impl, item)