ensure_future -> create_task
This commit is contained in:
1 parent
2797f5ee68
commit
2306fc1331
1 file changed
+3
-3
@@ -1922,12 +1922,12 @@ class GUIManager:
|
|||||||
# wait until the user closes the window
|
# wait until the user closes the window
|
||||||
await self._close_requested.wait()
|
await self._close_requested.wait()
|
||||||
|
|
||||||
async def coro_unless_closed(self, coro: abc.Awaitable[_T]) -> _T:
|
async def coro_unless_closed(self, coro: Any) -> _T:
|
||||||
# In Python 3.11, we need to explicitly wrap awaitables
|
# In Python 3.11, we need to explicitly wrap awaitables
|
||||||
future: asyncio.Future[_T] = asyncio.ensure_future(coro)
|
task = asyncio.create_task(coro)
|
||||||
done: set[asyncio.Task[Any]]
|
done: set[asyncio.Task[Any]]
|
||||||
done, pending = await asyncio.wait(
|
done, pending = await asyncio.wait(
|
||||||
[future, self._close_requested.wait()],
|
[task, self._close_requested.wait()],
|
||||||
return_when=asyncio.FIRST_COMPLETED,
|
return_when=asyncio.FIRST_COMPLETED,
|
||||||
)
|
)
|
||||||
for task in pending:
|
for task in pending:
|
||||||
|
|||||||
Reference in new issue
Block a user