tiny.http.ChunkedWriter

1pub const ChunkedWriter = struct {2    conn: *Connection,3    allocator: std.mem.Allocator,4    headers_sent: bool,56    pub fn init(conn: *Connection, allocator: std.mem.Allocator) ChunkedWriter {7        return .{8            .conn = conn,9            .allocator = allocator,10            .headers_sent = false,11        };12    }1314    pub fn writeHeader(15        self: *ChunkedWriter,16        status: u16,17        status_text: []const u8,18        headers: []const struct { name: []const u8, value: []const u8 },19    ) !void {20        if (self.headers_sent) return;2122        var buf: std.ArrayListUnmanaged(u8) = .empty;23        defer buf.deinit(self.allocator);2425        try buf.writer(self.allocator).print("HTTP/1.1 {d} {s}\r\n", .{ status, status_text });2627        for (headers) |header| {28            try buf.writer(self.allocator).print("{s}: {s}\r\n", .{ header.name, header.value });29        }3031        try buf.appendSlice(self.allocator, "Transfer-Encoding: chunked\r\n");32        try buf.appendSlice(self.allocator, "\r\n");3334        try self.conn.write(buf.items);35        self.headers_sent = true;36    }3738    pub fn chunk(self: *ChunkedWriter, data: []const u8) !void {39        if (data.len == 0) return;4041        var header_buf: [32]u8 = undefined;42        const header = std.fmt.bufPrint(&header_buf, "{x}\r\n", .{data.len}) catch unreachable;4344        try self.conn.write(header);45        try self.conn.write(data);46        try self.conn.write("\r\n");47    }4849    pub fn finish(self: *ChunkedWriter) !void {50        try self.conn.write("0\r\n\r\n");51    }52};

1pub const ChunkedWriter = writer.ChunkedWriter;