(self, async_engine, filter_)
| 1210 | @testing.combinations((None,), ("mappings",), argnames="filter_") |
| 1211 | @async_test |
| 1212 | async def test_keys(self, async_engine, filter_): |
| 1213 | users = self.tables.users |
| 1214 | async with async_engine.connect() as conn: |
| 1215 | result = await conn.stream(select(users)) |
| 1216 | |
| 1217 | if filter_ == "mappings": |
| 1218 | result = result.mappings() |
| 1219 | |
| 1220 | eq_(result.keys(), ["user_id", "user_name"]) |
| 1221 | |
| 1222 | await result.close() |
| 1223 | |
| 1224 | @async_test |
| 1225 | async def test_unique_all(self, async_engine): |