(self)
| 379 | self._time += advance |
| 380 | |
| 381 | def close(self): |
| 382 | super().close() |
| 383 | if self._check_on_close: |
| 384 | try: |
| 385 | self._gen.send(0) |
| 386 | except StopIteration: |
| 387 | pass |
| 388 | else: # pragma: no cover |
| 389 | raise AssertionError("Time generator is not finished") |
| 390 | |
| 391 | def _add_reader(self, fd, callback, *args, context=None): |
| 392 | self.readers[fd] = events.Handle(callback, args, self, context) |