propagate lost server connection errors to client

- set exception on response future when connection to server is lost
coinkite · Jul 31, 2024 · e631fb9 · e631fb9
1 parent c893bc2
commit e631fb9
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/connectrum/client.py b/connectrum/client.py
@@ -61,6 +61,11 @@ def _connection_lost(self, protocol):
         self.protocol = None
         logger.warn("Electrum server connection lost")
 
+        for (_, fut) in self.inflight.values():
+            fut.set_exception(ElectrumErrorResponse("Electrum server connection lost"))
+
+        self.inflight.clear()
+
         # cleanup keep alive task
         if self.ka_task:
             self.ka_task.cancel()