From 99ea7556581a678684e30202a8eee654a001588a Mon Sep 17 00:00:00 2001
From: Robby Zambito <contact@robbyzambito.me>
Date: Sat, 10 Jan 2026 11:37:26 -0500
Subject: Send should be uncancelable

---
 src/Server.zig | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

(limited to 'src')

diff --git a/src/Server.zig b/src/Server.zig
index 65129a5..e20f5c0 100644
--- a/src/Server.zig
+++ b/src/Server.zig
@@ -43,7 +43,9 @@ const Subscription = struct {
         try self.queue_lock.lock(io);
         defer self.queue_lock.unlock(io);
         for (bytes) |chunk| {
-            try self.queue.putAll(io, chunk);
+            // Uncancelable because canceling the sender in the middle of this loop
+            // would put an invalid set series of bytes in the receivers queue.
+            _ = try self.queue.putUncancelable(io, chunk, chunk.len);
         }
     }
 };
-- 
cgit