(self)
| 72 | """ |
| 73 | |
| 74 | def __init__(self): |
| 75 | self._loop = asyncio.new_event_loop() |
| 76 | threading.Thread(target=self._loop.run_forever, daemon=True).start() |
| 77 | self._queue: asyncio.Queue = self._call(asyncio.Queue) |
| 78 | asyncio.run_coroutine_threadsafe(self._run(), self._loop) |
| 79 | |
| 80 | def _call(self, fn): |
| 81 | fut: concurrent.futures.Future = concurrent.futures.Future() |