97 mbps !!! super fast

dosen't flush every message, pulls batches from the queue to send, and flushes at the end of each batch.
batches are a min of 1 message, but may be more.

1 files changed, 4 insertions, 3 deletions

diff --git a/src/server/main.zig b/src/server/main.zig
index e622304..d8e8e61 100644
--- a/src/server/main.zig
+++ b/src/server/main.zig
@@ -126,12 +126,12 @@ fn handleConnection(
     const allocator = if (builtin.mode == .Debug or builtin.mode == .ReleaseSafe) client_allocator.allocator() else server_allocator;
 
     // Set up client writer
-    var w_buffer: [256]u8 = undefined;
+    var w_buffer: [1024]u8 = undefined;
     var writer = stream.writer(io, &w_buffer);
     const out = &writer.interface;
 
     // Set up client reader
-    var r_buffer: [256]u8 = undefined;
+    var r_buffer: [1024]u8 = undefined;
     var reader = stream.reader(io, &r_buffer);
     const in = &reader.interface;
 
@@ -140,8 +140,9 @@ fn handleConnection(
     try server.addClient(server_allocator, id, &client);
     defer server.removeClient(io, server_allocator, id);
 
-    var qbuf: [16]Message = undefined;
+    var qbuf: [8]Message = undefined;
     var queue: std.Io.Queue(Message) = .init(&qbuf);
+    defer queue.close(io);
 
     var client_task = try io.concurrent(Client.start, .{ &client, io, server_allocator, &queue });
     defer client_task.cancel(io) catch {};