(self)
| 34 | return not self.event.is_set() |
| 35 | |
| 36 | def run(self): |
| 37 | try: |
| 38 | asyncio.set_event_loop(self.loop) |
| 39 | self.loop.run_until_complete(self.listen()) |
| 40 | except Exception as e: |
| 41 | logger.warning("Reactor.run() => %s", e) |
| 42 | |
| 43 | async def _wait_service_started(self): |
| 44 | while True: |
no test coverage detected