db.py 文件源码

def test_pubsub():
    async with create_pool(get_db_url()) as e:
        async with e.acquire() as listen_conn:
            listener = listen_helper(listen_conn)
            db = Database()
            await db.startup()
            await asyncio.gather(listener, db.insert_post(parent_id=290, content='testing notify'))
            print("listen/notify done!")