(aconn_cls, aconn, dsn)
| 134 | @pytest.mark.slow |
| 135 | @pytest.mark.timing |
| 136 | async def test_notify_timeout_0(aconn_cls, aconn, dsn): |
| 137 | await aconn.set_autocommit(True) |
| 138 | await aconn.execute("listen foo") |
| 139 | |
| 140 | ns = await alist(aconn.notifies(timeout=0)) |
| 141 | assert not ns |
| 142 | |
| 143 | async with await aconn_cls.connect(dsn, autocommit=True) as nconn: |
| 144 | await nconn.execute("notify foo, '1'") |
| 145 | await asleep(0.1) |
| 146 | |
| 147 | ns = await alist(aconn.notifies(timeout=0)) |
| 148 | assert len(ns) == 1 |
| 149 | |
| 150 | |
| 151 | @pytest.mark.slow |