(self, n)
| 331 | self._notify(n) |
| 332 | |
| 333 | def _notify(self, n): |
| 334 | idx = 0 |
| 335 | for fut in self._waiters: |
| 336 | if idx >= n: |
| 337 | break |
| 338 | |
| 339 | if not fut.done(): |
| 340 | idx += 1 |
| 341 | fut.set_result(False) |
| 342 | |
| 343 | def notify_all(self): |
| 344 | """Wake up all tasks waiting on this condition. This method acts |
no test coverage detected