Unblock receive() call on timeout disconnections (#33)

miguelgrinberg · Dec 27, 2023 · 5a5dbec · 5a5dbec
1 parent a9483e5
commit 5a5dbec
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/simple_websocket/ws.py b/src/simple_websocket/ws.py
@@ -143,6 +143,7 @@ def _thread(self):
                         if not self.pong_received:
                             self.close(reason=CloseReason.POLICY_VIOLATION,
                                        message='Ping/Pong timeout')
+                            self.event.set()
                             break
                         self.pong_received = False
                         self.sock.send(self.ws.send(Ping()))