We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d6d1b03 commit 233af4eCopy full SHA for 233af4e
src/textual_dev/service.py
@@ -276,11 +276,11 @@ async def close(self) -> None:
276
277
# Stop any writes to the websocket first
278
await self.outgoing_queue.put(None)
279
- await self.outgoing_messages_task
+ await asyncio.shield(self.outgoing_messages_task)
280
281
# Now we can shut the socket down
282
await self.websocket.close()
283
284
# This task is independent of the websocket
285
await self.incoming_queue.put(None)
286
- await self.incoming_messages_task
+ await asyncio.shield(self.incoming_messages_task)
0 commit comments