Merge branch 'master' into fix-async-iter-for-sa-connection-context-m…

…anager

CHANGES.txt

@@ -18,6 +18,7 @@ To be included in 1.0.0 (unreleased)
 * Bump minimal PyMySQL version to 1.0.0 #713
 * Align % formatting in Cursor.executemany() with Cursor.execute(), literal % now need to be doubled in Cursor.executemany() #714
 * Fixed unlimited Pool size not working, this is now working as documented by passing maxsize=0 to create_pool #119
+* Added Pool.closed property as present in aiopg #463
 * Fixed SQLAlchemy connection context iterator #410
 
 

aiomysql/pool.py

@@ -1,4 +1,4 @@
-# copied from aiopg
+# based on aiopg pool
 # https://github.com/aio-libs/aiopg/blob/master/aiopg/pool.py
 
 import asyncio
@@ -79,6 +79,13 @@ async def clear(self):
                 await conn.ensure_closed()
             self._cond.notify()
 
+    @property
+    def closed(self):
+        """
+        The readonly property that returns ``True`` if connections is closed.
+        """
+        return self._closed
+
     def close(self):
         """Close pool.
 

tests/test_pool.py

@@ -345,6 +345,7 @@ async def wait_closed():
     await asyncio.gather(wait_closed(), do_release(c1), do_release(c2))
     assert ['release', 'release', 'wait_closed'] == ops
     assert 0 == pool.freesize
+    assert pool.closed
 
 
 @pytest.mark.run_loop