diff --git a/ipc_unix/pubsub.py b/ipc_unix/pubsub.py index 1bae3cf..8dc776c 100644 --- 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):