FIX: invalid state (#87)

xorbitsai · Jul 10, 2024 · 1d148fa · 1d148fa
1 parent 5ffa0ea
commit 1d148fa
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/python/xoscar/backends/core.py b/python/xoscar/backends/core.py
@@ -85,7 +85,8 @@ async def _listen(self, client: Client):
                         f"Remote server {client.dest_address} closed"
                     ) from None
                 future = self._client_to_message_futures[client].pop(message.message_id)
-                future.set_result(message)
+                if not future.done():
+                    future.set_result(message)
             except DeserializeMessageFailed as e:
                 message_id = e.message_id
                 future = self._client_to_message_futures[client].pop(message_id)