Lock subs when reading it

should probably make a copy instead of doing io in the mutex

1 files changed, 2 insertions, 0 deletions

diff --git a/src/server/main.zig b/src/server/main.zig
index 012aa98..fb4e698 100644
--- a/src/server/main.zig
+++ b/src/server/main.zig
@@ -202,6 +202,8 @@ fn publishMessage(server: *Server, io: std.Io, alloc: std.mem.Allocator, source_
         }
     }
     defer msg.deinit(alloc);
+    try server.subs_lock.lock(io);
+    defer server.subs_lock.unlock(io);
     for (server.subscriptions.items) |subscription| {
         if (subjectMatches(subscription.subject, msg.subject)) {
             const client = server.clients.get(subscription.client_id) orelse {