(self, async_engine)
| 1294 | |
| 1295 | @async_test |
| 1296 | async def test_unique_all(self, async_engine): |
| 1297 | users = self.tables.users |
| 1298 | async with async_engine.connect() as conn: |
| 1299 | result = await conn.stream( |
| 1300 | union_all(select(users), select(users)).order_by( |
| 1301 | users.c.user_id |
| 1302 | ) |
| 1303 | ) |
| 1304 | |
| 1305 | all_ = await result.unique().all() |
| 1306 | eq_(all_, [(i, "name%d" % i) for i in range(1, 20)]) |
| 1307 | |
| 1308 | @async_test |
| 1309 | async def test_columns_all(self, async_engine): |