@pytest.mark.slow
+@pytest.mark.timing
def test_notify_timeout_0(conn_cls, conn, dsn):
conn.set_autocommit(True)
conn.execute("listen foo")
@pytest.mark.slow
+@pytest.mark.timing
def test_stop_after(conn_cls, conn, dsn):
conn.set_autocommit(True)
conn.execute("listen foo")
assert ns[0].payload == "3"
+@pytest.mark.timing
def test_stop_after_batch(conn_cls, conn, dsn):
conn.set_autocommit(True)
conn.execute("listen foo")
@pytest.mark.slow
+@pytest.mark.timing
def test_notifies_blocking(conn):
def listener():
@pytest.mark.slow
+@pytest.mark.timing
async def test_notify_timeout_0(aconn_cls, aconn, dsn):
await aconn.set_autocommit(True)
await aconn.execute("listen foo")
@pytest.mark.slow
+@pytest.mark.timing
async def test_stop_after(aconn_cls, aconn, dsn):
await aconn.set_autocommit(True)
await aconn.execute("listen foo")
assert ns[0].payload == "3"
+@pytest.mark.timing
async def test_stop_after_batch(aconn_cls, aconn, dsn):
await aconn.set_autocommit(True)
await aconn.execute("listen foo")
@pytest.mark.slow
+@pytest.mark.timing
async def test_notifies_blocking(aconn):
async def listener():
async for _ in aconn.notifies(timeout=1):