diff options
| -rw-r--r-- | src/server/main.zig | 2 |
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 { |