Skip to content

Commit 4fcb479

Browse files
committed
don't forget to advance in the deprecated adapter
1 parent 6038192 commit 4fcb479

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

lib/std/Io.zig

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -334,10 +334,12 @@ pub fn GenericReader(
334334
fn stream(r: *Reader, w: *Writer, limit: Limit) Reader.StreamError!usize {
335335
const a: *@This() = @alignCast(@fieldParentPtr("new_interface", r));
336336
const buf = limit.slice(try w.writableSliceGreedy(1));
337-
return a.derp_reader.read(buf) catch |err| {
337+
const n = a.derp_reader.read(buf) catch |err| {
338338
a.err = err;
339339
return error.ReadFailed;
340340
};
341+
w.advance(n);
342+
return n;
341343
}
342344
};
343345
};

lib/std/Io/DeprecatedReader.zig

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -393,10 +393,12 @@ pub const Adapter = struct {
393393
fn stream(r: *std.io.Reader, w: *std.io.Writer, limit: std.io.Limit) std.io.Reader.StreamError!usize {
394394
const a: *@This() = @alignCast(@fieldParentPtr("new_interface", r));
395395
const buf = limit.slice(try w.writableSliceGreedy(1));
396-
return a.derp_reader.read(buf) catch |err| {
396+
const n = a.derp_reader.read(buf) catch |err| {
397397
a.err = err;
398398
return error.ReadFailed;
399399
};
400+
w.advance(n);
401+
return n;
400402
}
401403
};
402404

0 commit comments

Comments
 (0)