Fix: ClientResponse.close() is not a coroutine

aiodocker/docker.py

@@ -522,16 +522,15 @@ async def run(self, **params):
                 self._transform_event,
                 human_bool(params['stream']),
             )
-            async for data in self.json_stream:
-                await self.channel.publish(data)
+            try:
+                async for data in self.json_stream:
+                    await self.channel.publish(data)
+            finally:
+                await self.json_stream.close()
+                self.json_stream = None
         finally:
             # signal termination to subscribers
             await self.channel.publish(None)
-            try:
-                await self.json_stream.close()
-            except:
-                pass
-            self.json_stream = None
 
     async def stop(self):
         if self.json_stream is not None:

aiodocker/jsonstream.py

@@ -42,7 +42,7 @@ async def close(self):
         # (see https://github.com/KeepSafe/aiohttp/issues/739)
 
         # response error , it has been closed
-        await self._response.close()
+        self._response.close()
 
 
 async def json_stream_result(response, transform=None, stream=True):

tests/test_integration.py

@@ -231,3 +231,5 @@ async def test_events(docker, testing_images, event_loop):
             break
 
     assert events_occurred == ['create', 'start', 'kill', 'die', 'destroy']
+
+    await docker.events.stop()