(self, async_engine)
| 1307 | |
| 1308 | @async_test |
| 1309 | async def test_columns_all(self, async_engine): |
| 1310 | users = self.tables.users |
| 1311 | async with async_engine.connect() as conn: |
| 1312 | result = await conn.stream(select(users)) |
| 1313 | |
| 1314 | all_ = await result.columns(1).all() |
| 1315 | eq_(all_, [("name%d" % i,) for i in range(1, 20)]) |
| 1316 | |
| 1317 | @testing.combinations( |
| 1318 | (None,), ("scalars",), ("mappings",), argnames="filter_" |