From ca95c9a06c3cfcdd759be30d764b9446308a9add Mon Sep 17 00:00:00 2001
From: Robby Zambito <contact@robbyzambito.me>
Date: Thu, 1 Jan 2026 18:41:19 +0000
Subject: Lock subs when reading it

should probably make a copy instead of doing io in the mutex
---
 src/server/main.zig | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'src')

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 {
-- 
cgit