(self, async_engine)
| 1236 | |
| 1237 | @async_test |
| 1238 | async def test_columns_all(self, async_engine): |
| 1239 | users = self.tables.users |
| 1240 | async with async_engine.connect() as conn: |
| 1241 | result = await conn.stream(select(users)) |
| 1242 | |
| 1243 | all_ = await result.columns(1).all() |
| 1244 | eq_(all_, [("name%d" % i,) for i in range(1, 20)]) |
| 1245 | |
| 1246 | @testing.combinations( |
| 1247 | (None,), ("scalars",), ("mappings",), argnames="filter_" |