(self, async_engine, filter_)
| 1281 | @testing.combinations((None,), ("mappings",), argnames="filter_") |
| 1282 | @async_test |
| 1283 | async def test_keys(self, async_engine, filter_): |
| 1284 | users = self.tables.users |
| 1285 | async with async_engine.connect() as conn: |
| 1286 | result = await conn.stream(select(users)) |
| 1287 | |
| 1288 | if filter_ == "mappings": |
| 1289 | result = result.mappings() |
| 1290 | |
| 1291 | eq_(result.keys(), ["user_id", "user_name"]) |
| 1292 | |
| 1293 | await result.close() |
| 1294 | |
| 1295 | @async_test |
| 1296 | async def test_unique_all(self, async_engine): |