summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorRobby Zambito <contact@robbyzambito.me>2026-01-02 19:53:51 +0000
committerRobby Zambito <contact@robbyzambito.me>2026-01-02 19:53:53 +0000
commit5f24108014cbf9048eaba862af5aaf2fa09be8e9 (patch)
treebed49afc95fc114bdb133fccf83b83b21b454cf2 /src
parent63749529415aa335eef2dc7c392f14efe4928dc7 (diff)
Don't assume capacity
Diffstat (limited to 'src')
-rw-r--r--src/server/message_parser.zig10
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