()
| 152 | await task |
| 153 | |
| 154 | async def test_race_with_precompleted_future(): |
| 155 | print("test_race_with_precompleted_future") |
| 156 | future1 = Future() |
| 157 | future2 = Future() |
| 158 | future1.resolve("immediate success") |
| 159 | # Immediately resolved future before race call |
| 160 | race_future = Future.race([future1, future2]) |
| 161 | result = await race_future |
| 162 | assert result == "immediate success", "Race did not correctly prioritize already completed future." |
| 163 | |
| 164 | async def test_closed_by_user(): |
| 165 | print("test_closed_by_user") |
no test coverage detected
searching dependent graphs…