(self)
| 476 | self.remove_writer_count = collections.defaultdict(int) |
| 477 | |
| 478 | def _run_once(self): |
| 479 | super()._run_once() |
| 480 | for when in self._timers: |
| 481 | advance = self._gen.send(when) |
| 482 | self.advance_time(advance) |
| 483 | self._timers = [] |
| 484 | |
| 485 | def call_at(self, when, callback, *args, context=None): |
| 486 | self._timers.append(when) |