(self)
| 8 | self.lock = asyncio.Lock() |
| 9 | |
| 10 | async def wait_to_ready(self): |
| 11 | try: |
| 12 | await asyncio.wait_for(self.event.wait(), timeout=3) |
| 13 | except asyncio.TimeoutError: |
| 14 | pass |
| 15 | |
| 16 | async def get_all_data(self): |
| 17 | async with self.lock: |
no outgoing calls
no test coverage detected