Commit 9292ded5a3b8c82ae731bb18d40c69b7e40177f8 | zig

author	Andrew Kelley <andrew@ziglang.org> 2026-04-05 02:17:53-07:00
committer	Andrew Kelley <andrew@ziglang.org> 2026-04-05 02:17:53-07:00
log	9292ded5a3b8c82ae731bb18d40c69b7e40177f8
tree	154bceeaf82e3e96caab244932939dbc7e34a4d3
parent	e73257dec2d997e9d573419178695992790a9525

closes #31730
closes #31757

2 files changed, 7 insertions(+), 6 deletions(-)

lib/std/Io.zig+2-2

...	@@ -500,8 +500,8 @@ pub const Batch = struct {	...	@@ -500,8 +500,8 @@ pub const Batch = struct {
500	/// Returns the index that will be returned by `next` after the operation completes.	500	/// Returns the index that will be returned by `next` after the operation completes.
501	/// Asserts that no more than `storage.len` operations are active at a time.	501	/// Asserts that no more than `storage.len` operations are active at a time.
502	pub fn add(batch: *Batch, operation: Operation) u32 {	502	pub fn add(batch: *Batch, operation: Operation) u32 {
503	const index = batch.unused.next;	503	const index = batch.unused.head.toIndex();
504	batch.addAt(index.toIndex(), operation);	504	batch.addAt(index, operation);
505	return index;	505	return index;
506	}	506	}
507		507

lib/std/Io/test.zig+5-4

 @@ -692,14 +692,15 @@ test "read from a file using Batch.awaitAsync API" {
     var storage: [2]Io.Operation.Storage = undefined;
     var batch: Io.Batch = .init(&storage);
-    batch.addAt(0, .{ .file_read_streaming = .{
+    // Tests add API because this provides coverage for both add and addAt.
+    try testing.expectEqual(0, batch.add(.{ .file_read_streaming = .{
         .file = eyes_file,
         .data = &.{&eyes_buf},
-    } });
+    } }));
-    batch.addAt(1, .{ .file_read_streaming = .{
+    try testing.expectEqual(1, batch.add(.{ .file_read_streaming = .{
         .file = saviour_file,
         .data = &.{&saviour_buf},
-    } });
+    } }));
     // This API is supposed to *always* work even if the target has no
     // concurrency primitives available.