Kill connections when closing publisher

2018-12-08 12:37:39 +00:00 · 2018-12-08 12:37:39 +00:00 · e605438d33
parent 07ed45780a
commit e605438d33
1 changed files with 2 additions and 0 deletions
--- a/ipc_unix/pubsub.py
+++ b/ipc_unix/pubsub.py
@ -44,6 +44,8 @@ class Publisher:

    def close(self):
        self.master_socket.close()
+        for connection in self.connections:
+            connection.close()
        self.connections.clear()

    def accept_new_connection(self):