Wait until acknowledge() is called after interrupt().
(self, timeout=None)
| 24 | self._ack_event.set() |
| 25 | |
| 26 | async def join(self, timeout=None): |
| 27 | """Wait until acknowledge() is called after interrupt().""" |
| 28 | try: |
| 29 | await asyncio.wait_for(self._ack_event.wait(), timeout) |
| 30 | except asyncio.TimeoutError: |
| 31 | raise RuntimeError("Timeout waiting for interruption to be acknowledged.") |
| 32 | |
| 33 | |
| 34 | _interruption_flags = {} |
no outgoing calls
no test coverage detected