tiny.pretty.TextWriter

1/// Adapts incremental text production to the Pretty renderer without allocating.2/// Flushes propagate to the wrapped writer so process-boundary ordering is preserved.3pub const TextWriter = struct {4    writer: std.Io.Writer,5    output: *std.Io.Writer,6    options: types.LayoutOptions,78    pub fn init(9        output: *std.Io.Writer,10        buffer: []u8,11        options: types.LayoutOptions,12    ) TextWriter {13        return .{14            .writer = .{15                .vtable = &.{16                    .drain = drain,17                    .flush = flush,18                },19                .buffer = buffer,20            },21            .output = output,22            .options = options,23        };24    }2526    fn drain(27        writer: *std.Io.Writer,28        data: []const []const u8,29        splat: usize,30    ) std.Io.Writer.Error!usize {31        const self: *TextWriter = @alignCast(@fieldParentPtr("writer", writer));32        std.debug.assert(data.len > 0);33        try self.write(writer.buffered());34        writer.end = 0;3536        var consumed: usize = 0;37        for (data[0 .. data.len - 1]) |bytes| {38            try self.write(bytes);39            consumed += bytes.len;40        }41        const pattern = data[data.len - 1];42        for (0..splat) |_| {43            try self.write(pattern);44            consumed += pattern.len;45        }46        return consumed;47    }4849    fn flush(writer: *std.Io.Writer) std.Io.Writer.Error!void {50        const self: *TextWriter = @alignCast(@fieldParentPtr("writer", writer));51        try self.write(writer.buffered());52        writer.end = 0;53        try self.output.flush();54    }5556    fn write(self: *TextWriter, bytes: []const u8) std.Io.Writer.Error!void {57        render.write(58            self.output,59            .{ .text = bytes },60            self.options,61        ) catch return error.WriteFailed;62    }63};

1pub const TextWriter = @import("stream.zig").TextWriter;