Call shutdown_asyncgens before loop closing (#2227)

* Call shutdown_asyncgens before loop closing

* Check for shutdown_asyncgens existance

* Add changes

aiohttp/web.py

@@ -464,6 +464,8 @@ def run_app(app, *, host=None, port=None, path=None, sock=None,
     finally:
         loop.run_until_complete(app.cleanup())
     if not user_supplied_loop:
+        if hasattr(loop, 'shutdown_asyncgens'):
+            loop.run_until_complete(loop.shutdown_asyncgens())
         loop.close()
 
 

aiohttp/worker.py

@@ -48,6 +48,8 @@ def run(self):
         try:
             self.loop.run_until_complete(self._runner)
         finally:
+            if hasattr(self.loop, 'shutdown_asyncgens'):
+                self.loop.run_until_complete(self.loop.shutdown_asyncgens())
             self.loop.close()
 
         sys.exit(self.exit_code)

changes/2227.feature

@@ -0,0 +1 @@
+Call `shutdown_asyncgens` before event loop closing on Python 3.6.