From 50870da1d9d5b80b01bb56461fc0c035bcd24b5b Mon Sep 17 00:00:00 2001
From: Robby Zambito <contact@robbyzambito.me>
Date: Tue, 9 Dec 2025 21:19:12 -0500
Subject: made some progress on subscriptions

---
 src/server/client.zig | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

(limited to 'src/server/client.zig')

diff --git a/src/server/client.zig b/src/server/client.zig
index 458bbbb..32a53b7 100644
--- a/src/server/client.zig
+++ b/src/server/client.zig
@@ -66,12 +66,14 @@ pub const ClientState = struct {
                 },
             }
         }
+        self.task.cancel(io);
     }
 
     pub fn deinit(self: *ClientState, io: std.Io, allocator: std.mem.Allocator) void {
         self.task.cancel(io);
         self.connect.deinit();
-        allocator.destroy(self.recv_queue);
+        _ = allocator;
+        // allocator.destroy(self.recv_queue);
     }
 
     /// Return true if the value was put in the clients buffer to process, else false.
@@ -95,14 +97,11 @@ fn writeOk(out: *std.Io.Writer) !void {
 }
 
 fn writePong(out: *std.Io.Writer) !void {
-    std.debug.print("out pointer: {*}\n", .{out});
-    std.debug.print("writing pong\n", .{});
     _ = try out.write("PONG\r\n");
     try out.flush();
 }
 
 pub fn writeInfo(out: *std.Io.Writer, info: Message.ServerInfo) !void {
-    std.debug.print("writing info: {any}\n", .{info});
     _ = try out.write("INFO ");
     try std.json.Stringify.value(info, .{}, out);
     _ = try out.write("\r\n");
-- 
cgit