diff options
| -rw-r--r-- | src/server/message_parser.zig | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/server/message_parser.zig b/src/server/message_parser.zig index 5639689..600741d 100644 --- a/src/server/message_parser.zig +++ b/src/server/message_parser.zig @@ -268,7 +268,7 @@ pub const Message = union(MessageType) { switch (operation) { .connect => { // for storing the json string - var connect_string_writer_allocating: std.Io.Writer.Allocating = try .initCapacity(alloc, 1024); + var connect_string_writer_allocating: std.Io.Writer.Allocating = .init(alloc); defer connect_string_writer_allocating.deinit(); var connect_string_writer = connect_string_writer_allocating.writer; @@ -323,7 +323,7 @@ pub const Message = union(MessageType) { } else break; } else |err| return err; - var acc: std.ArrayList(u8) = try .initCapacity(alloc, 32); + var acc: std.ArrayList(u8) = .empty; errdefer acc.deinit(alloc); while (in.peekByte()) |byte| { if (std.ascii.isWhitespace(byte)) break; @@ -355,7 +355,7 @@ pub const Message = union(MessageType) { } // Parse sid const sid = blk: { - var acc: std.ArrayList(u8) = try .initCapacity(alloc, 8); + var acc: std.ArrayList(u8) = .empty; errdefer acc.deinit(alloc); while (in.peekByte()) |byte| { if (std.ascii.isWhitespace(byte)) break; @@ -376,7 +376,7 @@ pub const Message = union(MessageType) { } else if (std.ascii.isWhitespace(try in.peekByte())) { in.toss(1); const max_msgs = blk: { - var max_msgs_list: std.ArrayList(u8) = try .initCapacity(alloc, 64); + var max_msgs_list: std.ArrayList(u8) = .empty; errdefer max_msgs_list.deinit(alloc); while (in.peekByte()) |byte| { if (std.ascii.isWhitespace(byte)) { @@ -717,7 +717,7 @@ test parseHPub { } fn readSubject(alloc: std.mem.Allocator, in: *std.Io.Reader) ![]const u8 { - var subject_list: std.ArrayList(u8) = try .initCapacity(alloc, 1024); + var subject_list: std.ArrayList(u8) = .empty; errdefer subject_list.deinit(alloc); // Handle the first character |