mirror of
https://github.com/xfgryujk/blivechat.git
synced 2025-03-13 11:20:42 +08:00
parent
3d9095536d
commit
5bdf2e41df
@ -184,7 +184,7 @@ async def _pop_task() -> TranslateTask:
|
||||
return queue.get_nowait()
|
||||
|
||||
done_future_set, pending_future_set = await asyncio.wait(
|
||||
[queue.get() for queue in _task_queues],
|
||||
[asyncio.create_task(queue.get()) for queue in _task_queues],
|
||||
return_when=asyncio.FIRST_COMPLETED
|
||||
)
|
||||
for future in pending_future_set:
|
||||
|
Loading…
Reference in New Issue
Block a user