authorgravatar for andrew@ziglang.orgAndrew Kelley <andrew@ziglang.org> 2025-08-01 00:24:35-07:00
committergravatar for andrew@ziglang.orgAndrew Kelley <andrew@ziglang.org> 2025-08-07 10:04:52-07:00
log262bfc58267543037499bc5a041918e74c36a029
treeebec8b0af7e3ca31f71f82c678c04dfac21818e9
parente061445fc227edc8229680bf0330fc3ea60e0e4f

std.Io: delete LimitedReader

2 files changed, 0 insertions(+), 49 deletions(-)

lib/std/Io.zig-4
...@@ -431,10 +431,6 @@ pub const bufferedWriter = @import("Io/buffered_writer.zig").bufferedWriter;...@@ -431,10 +431,6 @@ pub const bufferedWriter = @import("Io/buffered_writer.zig").bufferedWriter;
431pub const FixedBufferStream = @import("Io/fixed_buffer_stream.zig").FixedBufferStream;431pub const FixedBufferStream = @import("Io/fixed_buffer_stream.zig").FixedBufferStream;
432/// Deprecated in favor of `Reader`.432/// Deprecated in favor of `Reader`.
433pub const fixedBufferStream = @import("Io/fixed_buffer_stream.zig").fixedBufferStream;433pub const fixedBufferStream = @import("Io/fixed_buffer_stream.zig").fixedBufferStream;
434/// Deprecated in favor of `Reader.Limited`.
435pub const LimitedReader = @import("Io/limited_reader.zig").LimitedReader;
436/// Deprecated in favor of `Reader.Limited`.
437pub const limitedReader = @import("Io/limited_reader.zig").limitedReader;
438/// Deprecated with no replacement; inefficient pattern434/// Deprecated with no replacement; inefficient pattern
439pub const CountingWriter = @import("Io/counting_writer.zig").CountingWriter;435pub const CountingWriter = @import("Io/counting_writer.zig").CountingWriter;
440/// Deprecated with no replacement; inefficient pattern436/// Deprecated with no replacement; inefficient pattern
lib/std/Io/limited_reader.zig deleted-45
...@@ -1,45 +0,0 @@
1const std = @import("../std.zig");
2const io = std.io;
3const assert = std.debug.assert;
4const testing = std.testing;
5
6pub fn LimitedReader(comptime ReaderType: type) type {
7 return struct {
8 inner_reader: ReaderType,
9 bytes_left: u64,
10
11 pub const Error = ReaderType.Error;
12 pub const Reader = io.GenericReader(*Self, Error, read);
13
14 const Self = @This();
15
16 pub fn read(self: *Self, dest: []u8) Error!usize {
17 const max_read = @min(self.bytes_left, dest.len);
18 const n = try self.inner_reader.read(dest[0..max_read]);
19 self.bytes_left -= n;
20 return n;
21 }
22
23 pub fn reader(self: *Self) Reader {
24 return .{ .context = self };
25 }
26 };
27}
28
29/// Returns an initialised `LimitedReader`.
30/// `bytes_left` is a `u64` to be able to take 64 bit file offsets
31pub fn limitedReader(inner_reader: anytype, bytes_left: u64) LimitedReader(@TypeOf(inner_reader)) {
32 return .{ .inner_reader = inner_reader, .bytes_left = bytes_left };
33}
34
35test "basic usage" {
36 const data = "hello world";
37 var fbs = std.io.fixedBufferStream(data);
38 var early_stream = limitedReader(fbs.reader(), 3);
39
40 var buf: [5]u8 = undefined;
41 try testing.expectEqual(@as(usize, 3), try early_stream.reader().read(&buf));
42 try testing.expectEqualSlices(u8, data[0..3], buf[0..3]);
43 try testing.expectEqual(@as(usize, 0), try early_stream.reader().read(&buf));
44 try testing.expectError(error.EndOfStream, early_stream.reader().skipBytes(10, .{}));
45}