authorgravatar for hello@nektro.netMeghan Denny <hello@nektro.net> 2026-01-02 19:10:41 -08:00
committergravatar for hello@nektro.netMeghan Denny <hello@nektro.net> 2026-01-02 19:10:41 -08:00
log4896f0e2a57c715d9db27c2500d138899674a972
tree9052fe74296436af6c028ef1cd82157dabe67fd3
parent68fb45670db28ceceecea9b8e4150b117d26967f

add Writable

1 files changed, 45 insertions(+), 0 deletions(-)

nio.zig+45
......@@ -89,6 +89,51 @@ pub fn Readable(T: type, this_kind: enum { _var, _const, _bare }) type {
8989 };
9090}
9191
92pub fn Writable(T: type, this_kind: enum { _var, _const, _bare }) type {
93 return struct {
94 const Error = T.WriteError;
95
96 const Self = switch (this_kind) {
97 ._var => *T,
98 ._const => *const T,
99 ._bare => T,
100 };
101
102 // pub fn write(self: Self, bytes: []const u8) Error!usize {
103 // }
104
105 pub fn writeAll(self: Self, bytes: []const u8) Error!void {
106 var index: usize = 0;
107 while (index != bytes.len) {
108 index += try self.write(bytes[index..]);
109 }
110 }
111
112 pub fn writeByteNTimes(self: Self, byte: u8, n: usize) Error!void {
113 var bytes: [1024]u8 = undefined;
114 @memset(bytes[0..], byte);
115 var remaining: usize = n;
116 while (remaining > 0) {
117 const to_write = @min(remaining, bytes.len);
118 try self.writeAll(bytes[0..to_write]);
119 remaining -= to_write;
120 }
121 }
122
123 pub fn writeInt(self: Self, comptime I: type, value: I, endian: std.builtin.Endian) Error!void {
124 var bytes: [@as(u16, @intCast((@as(u17, @typeInfo(I).Int.bits) + 7) / 8))]u8 = undefined;
125 std.mem.writeInt(std.math.ByteAlignedInt(I), &bytes, value, endian);
126 return self.writeAll(&bytes);
127 }
128
129 pub fn writeStruct(self: Self, value: anytype) Error!void {
130 // Only extern and packed structs have defined in-memory layout.
131 comptime std.debug.assert(@typeInfo(@TypeOf(value)).Struct.layout != .Auto);
132 return self.writeAll(std.mem.asBytes(&value));
133 }
134 };
135}
136
92137pub const AnyReadable = @import("./AnyReadable.zig");
93138
94139pub const FixedBufferStream = @import("./fixed_buffer_stream.zig").FixedBufferStream;