Fix compatibility with aiohttp>=3

aiohttp.Timeout is no longer available

Author: atx

setup.py

@@ -49,7 +49,7 @@
 
 if sys.version_info > (3, 4, 2):
     async_require.append('aiohttp>=1.0')
-    tests_require.append('aioresponses>=0.1.3')
+    tests_require.append('aioresponses>=0.4.1')
 
 
 with open('README.rst') as fh:

src/zeep/asyncio/transport.py

@@ -40,15 +40,14 @@ def __init__(self, loop, cache=None, timeout=300, operation_timeout=None,
 
     def __del__(self):
         if self._close_session:
-            self.session.close()
+            self.session.connector.close()
 
     def _load_remote_data(self, url):
         result = None
 
         async def _load_remote_data_async():
             nonlocal result
-            with aiohttp.Timeout(self.load_timeout):
-                response = await self.session.get(url)
+            async with self.session.get(url, timeout=self.load_timeout) as response:
                 result = await response.read()
                 try:
                     response.raise_for_status()
@@ -65,9 +64,8 @@ async def _load_remote_data_async():
 
     async def post(self, address, message, headers):
         self.logger.debug("HTTP Post to %s:\n%s", address, message)
-        with aiohttp.Timeout(self.operation_timeout):
-            response = await self.session.post(
-                address, data=message, headers=headers)
+        async with self.session.post(address, data=message, headers=headers,
+                                     timeout=self.operation_timeout) as response:
             self.logger.debug(
                 "HTTP Response from %s (status: %d):\n%s",
                 address, response.status, await response.read())
@@ -79,9 +77,8 @@ async def post_xml(self, address, envelope, headers):
         return await self.new_response(response)
 
     async def get(self, address, params, headers):
-        with aiohttp.Timeout(self.operation_timeout):
-            response = await self.session.get(
-                address, params=params, headers=headers)
+        async with self.session.get(address, params=params, headers=headers,
+                                    timeout=self.operation_timeout) as response:
 
             return await self.new_response(response)