diff --git a/tc_aws/loaders/s3_loader.py b/tc_aws/loaders/s3_loader.py
index 9a70a38..bd08247 100644
--- a/tc_aws/loaders/s3_loader.py
+++ b/tc_aws/loaders/s3_loader.py
@@ -63,7 +63,8 @@ async def load(context, url):
         return result
 
     result.successful = True
-    result.buffer = await file_key['Body'].read()
+    async with file_key['Body'] as stream:
+        result.buffer = await stream.read()
 
     result.metadata.update(
         size=file_key['ContentLength'],
diff --git a/tc_aws/result_storages/s3_storage.py b/tc_aws/result_storages/s3_storage.py
index a801a6e..601f7df 100644
--- a/tc_aws/result_storages/s3_storage.py
+++ b/tc_aws/result_storages/s3_storage.py
@@ -60,7 +60,8 @@ async def get(self, path = None):
             return None
 
         result = ResultStorageResult()
-        result.buffer = await key['Body'].read()
+        async with key['Body'] as stream:
+            result.buffer = await stream.read()
         result.successful = True
 
         result.metadata = {
diff --git a/tc_aws/storages/s3_storage.py b/tc_aws/storages/s3_storage.py
index 14ed488..f258c28 100644
--- a/tc_aws/storages/s3_storage.py
+++ b/tc_aws/storages/s3_storage.py
@@ -109,7 +109,8 @@ async def get_crypto(self, path):
             logger.warn("[STORAGE] s3 key not found at %s" % crypto_path)
             return None
 
-        file_key = await file_key['Body'].read()
+        async with file_key['Body'] as stream:
+            file_key = await stream.read()
 
         return file_key.decode('utf-8')
 
@@ -129,7 +130,8 @@ async def get_detector_data(self, path):
         if not file_key or self.is_expired(file_key) or 'Body' not in file_key:
             return None
 
-        return loads(await file_key['Body'].read())
+        async with file_key['Body'] as stream:
+            return loads(await stream.read())
 
     async def get(self, path):
         """
@@ -142,7 +144,8 @@ async def get(self, path):
         except BotoCoreError:
             return None
 
-        return await file['Body'].read()
+        async with file['Body'] as stream:
+            return await stream.read()
 
     async def exists(self, path):
         """