Send should be uncancelable

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