Function test_cursor_stream

tests/test_pipeline.py:111–114

(conn)

def test_cursor_stream(conn):
    with conn.pipeline(), conn.cursor() as cur:
        with pytest.raises(psycopg.ProgrammingError):
            next(cur.stream("select 1"))


def test_server_cursor(conn):