jshiffer/slixmpp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix running process() with a timeout (closes #3505)

Browse Source
This commit is contained in:
mathieui 2024-02-02 01:00:25 +01:00
parent 992d80dd09
commit 7128ea249b
No known key found for this signature in database
GPG Key ID: C59F84CEEFD616E3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
slixmpp/xmlstream/xmlstream.py
View File

@ -524,7 +524,7 @@ class XMLStream(asyncio.BaseProtocol):
else: else:
self.loop.run_until_complete(self.disconnected) self.loop.run_until_complete(self.disconnected)
else: else:
tasks: List[Awaitable] = [asyncio.sleep(timeout)] tasks: List[Awaitable] = [asyncio.Task(asyncio.sleep(timeout))]
if not forever: if not forever:
tasks.append(self.disconnected) tasks.append(self.disconnected)
self.loop.run_until_complete(asyncio.wait(tasks)) self.loop.run_until_complete(asyncio.wait(tasks))