(self)
| 14 | pass |
| 15 | |
| 16 | async def get_all_data(self): |
| 17 | async with self.lock: |
| 18 | self.event.clear() |
| 19 | ans = self.datas |
| 20 | self.datas = [] |
| 21 | return ans |
| 22 | |
| 23 | async def put(self, obj): |
| 24 | async with self.lock: |
no outgoing calls
no test coverage detected