(self, timeout=None)
| 241 | self._marked_for_shutdown = True |
| 242 | |
| 243 | def wait(self, timeout=None) -> None: |
| 244 | if self == threading.current_thread(): |
| 245 | # we are in the callback thread and thus cannot |
| 246 | # wait for the thread-loop to finish. |
| 247 | return |
| 248 | self.join(timeout=timeout) |
| 249 | |
| 250 | def run(self) -> None: |
| 251 | """get and run events until shutdown.""" |
no outgoing calls