(self, method: str, *args, **kwargs)
| 254 | return future |
| 255 | |
| 256 | async def execute_method_async(self, method: str, *args, **kwargs): |
| 257 | future = asyncio.get_running_loop().create_future() |
| 258 | self._enqueue_task(future, method, args, kwargs) |
| 259 | return await future |
| 260 | |
| 261 | def terminate_worker(self): |
| 262 | try: |
nothing calls this directly
no test coverage detected