Send should be uncancelable

1 files changed, 3 insertions, 1 deletions

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);
         }
     }
 };