Call a coroutine on the asyncio thread
(coro)
| 216 | event_loop = self.event_loop |
| 217 | |
| 218 | def in_thread(coro): |
| 219 | """Call a coroutine on the asyncio thread""" |
| 220 | return asyncio.run_coroutine_threadsafe(coro, event_loop).result() |
| 221 | |
| 222 | async def _readchunk(stream): |
| 223 | try: |