1 files changed, 78 insertions, 0 deletions
diff --git a/tests/pool/test_pool_async_noasyncio.py b/tests/pool/test_pool_async_noasyncio.py
new file mode 100644
index 0000000..f6e34e4
--- /dev/null
+++ b/tests/pool/test_pool_async_noasyncio.py
@@ -0,0 +1,78 @@
+# These tests relate to AsyncConnectionPool, but are not marked asyncio
+# because they rely on the pool initialization outside the asyncio loop.
+
+import asyncio
+
+import pytest
+
+from ..utils import gc_collect
+
+try:
+    import psycopg_pool as pool
+except ImportError:
+    # Tests should have been skipped if the package is not available
+    pass
+
+
+@pytest.mark.slow
+def test_reconnect_after_max_lifetime(dsn, asyncio_run):
+    # See issue #219, pool created before the loop.
+    p = pool.AsyncConnectionPool(dsn, min_size=1, max_lifetime=0.2, open=False)
+
+    async def test():
+        try:
+            await p.open()
+            ns = []
+            for i in range(5):
+                async with p.connection() as conn:
+                    cur = await conn.execute("select 1")
+                    ns.append(await cur.fetchone())
+                await asyncio.sleep(0.2)
+            assert len(ns) == 5
+        finally:
+            await p.close()
+
+    asyncio_run(asyncio.wait_for(test(), timeout=2.0))
+
+
+@pytest.mark.slow
+def test_working_created_before_loop(dsn, asyncio_run):
+    p = pool.AsyncNullConnectionPool(dsn, open=False)
+
+    async def test():
+        try:
+            await p.open()
+            ns = []
+            for i in range(5):
+                async with p.connection() as conn:
+                    cur = await conn.execute("select 1")
+                    ns.append(await cur.fetchone())
+                await asyncio.sleep(0.2)
+            assert len(ns) == 5
+        finally:
+            await p.close()
+
+    asyncio_run(asyncio.wait_for(test(), timeout=2.0))
+
+
+def test_cant_create_open_outside_loop(dsn):
+    with pytest.raises(RuntimeError):
+        pool.AsyncConnectionPool(dsn, open=True)
+
+
+@pytest.fixture
+def asyncio_run(recwarn):
+    """Fixture reuturning asyncio.run, but managing resources at exit.
+
+    In certain runs, fd objects are leaked and the error will only be caught
+    downstream, by some innocent test calling gc_collect().
+    """
+    recwarn.clear()
+    try:
+        yield asyncio.run
+    finally:
+        gc_collect()
+        if recwarn:
+            warn = recwarn.pop(ResourceWarning)
+            assert "unclosed event loop" in str(warn.message)
+            assert not recwarn