Skip to content

Commit ff165aa

Browse files
author
Tony Crisci
committed
add check for future done in aio reply handler
1 parent dba31fa commit ff165aa

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

dbus_next/aio/message_bus.py

+5-4
Original file line numberDiff line numberDiff line change
@@ -211,10 +211,11 @@ async def call(self, msg: Message) -> Optional[Message]:
211211
future = self._loop.create_future()
212212

213213
def reply_handler(reply, err):
214-
if err:
215-
future.set_exception(err)
216-
else:
217-
future.set_result(reply)
214+
if not future.done():
215+
if err:
216+
future.set_exception(err)
217+
else:
218+
future.set_result(reply)
218219

219220
self._call(msg, reply_handler)
220221

0 commit comments

Comments
 (0)