| 1373 | @testing.combinations(("scalars",), ("stream_scalars",), argnames="case") |
| 1374 | @async_test |
| 1375 | async def test_scalars(self, async_engine, case): |
| 1376 | users = self.tables.users |
| 1377 | stmt = select(users).order_by(users.c.user_id) |
| 1378 | async with async_engine.connect() as conn: |
| 1379 | if case == "scalars": |
| 1380 | result = (await conn.scalars(stmt)).all() |
| 1381 | elif case == "stream_scalars": |
| 1382 | result = await (await conn.stream_scalars(stmt)).all() |
| 1383 | |
| 1384 | eq_(result, list(range(1, 20))) |
| 1385 | |
| 1386 | @async_test |
| 1387 | @testing.combinations(("stream",), ("stream_scalars",), argnames="case") |