(self, timeout, description)
| 369 | run_exit_thread(f"{global_name}_exit", self.process, self.events, allow_unclean_exit) |
| 370 | |
| 371 | def register_timeout(self, timeout, description): |
| 372 | timeout_id = self.next_timeout_id |
| 373 | self.next_timeout_id += 1 |
| 374 | self.timeout_queue.put((timeout_id, TimeoutParam(timeout, description))) |
| 375 | return timeout_id |
| 376 | |
| 377 | def next_event(self, timeout_id): |
| 378 | event = self.events.get() |
no test coverage detected