From 810e5f82113a0e3b24c4ad0b66afa045b86372df Mon Sep 17 00:00:00 2001 From: Robby Zambito Date: Fri, 2 Jan 2026 14:11:00 +0000 Subject: Much better cleanup, still fast B) --- src/server/main.zig | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'src/server/main.zig') diff --git a/src/server/main.zig b/src/server/main.zig index aad842c..fca0dee 100644 --- a/src/server/main.zig +++ b/src/server/main.zig @@ -233,12 +233,12 @@ fn publishMessage(server: *Server, io: std.Io, alloc: std.mem.Allocator, source_ std.debug.print("trying to publish to a client that no longer exists: {d}\n", .{subscription.client_id}); continue; }; - client.send(io, .{ .msg = .{ - .subject = try alloc.dupe(u8, msg.subject), - .sid = try alloc.dupe(u8, subscription.sid), - .reply_to = if (msg.reply_to) |r| try alloc.dupe(u8, r) else null, - .payload = try alloc.dupe(u8, msg.payload), - } }) catch continue; + client.send(io, .{ + .msg = try msg.toMsg(alloc, subscription.sid), + }) catch |err| switch (err) { + error.Canceled => return err, + else => {}, + }; } } if (source_client.connect) |c| { -- cgit