| ... | ... | @@ -2126,7 +2126,7 @@ fn sendMessage(io: Io, file: Io.File, tag: std.zig.Client.Message.Tag) !void { |
| 2126 | 2126 | .tag = tag, |
| 2127 | 2127 | .bytes_len = 0, |
| 2128 | 2128 | }; |
| 2129 | | var w = file.writer(io, &.{}); |
| 2129 | var w = file.writerStreaming(io, &.{}); |
| 2130 | 2130 | w.interface.writeStruct(header, .little) catch |err| switch (err) { |
| 2131 | 2131 | error.WriteFailed => return w.err.?, |
| 2132 | 2132 | }; |
| ... | ... | @@ -2137,7 +2137,7 @@ fn sendRunTestMessage(io: Io, file: Io.File, tag: std.zig.Client.Message.Tag, in |
| 2137 | 2137 | .tag = tag, |
| 2138 | 2138 | .bytes_len = 4, |
| 2139 | 2139 | }; |
| 2140 | | var w = file.writer(io, &.{}); |
| 2140 | var w = file.writerStreaming(io, &.{}); |
| 2141 | 2141 | w.interface.writeStruct(header, .little) catch |err| switch (err) { |
| 2142 | 2142 | error.WriteFailed => return w.err.?, |
| 2143 | 2143 | }; |
| ... | ... | @@ -2157,7 +2157,7 @@ fn sendRunFuzzTestMessage( |
| 2157 | 2157 | .tag = .start_fuzzing, |
| 2158 | 2158 | .bytes_len = 4 + 1 + 8, |
| 2159 | 2159 | }; |
| 2160 | | var w = file.writer(io, &.{}); |
| 2160 | var w = file.writerStreaming(io, &.{}); |
| 2161 | 2161 | w.interface.writeStruct(header, .little) catch |err| switch (err) { |
| 2162 | 2162 | error.WriteFailed => return w.err.?, |
| 2163 | 2163 | }; |
| ... | ... | @@ -2202,7 +2202,7 @@ fn evalGeneric(run: *Run, spawn_options: process.SpawnOptions) !EvalGenericResul |
| 2202 | 2202 | var read_buffer: [1024]u8 = undefined; |
| 2203 | 2203 | var file_reader = file.reader(io, &read_buffer); |
| 2204 | 2204 | var write_buffer: [1024]u8 = undefined; |
| 2205 | | var stdin_writer = child.stdin.?.writer(io, &write_buffer); |
| 2205 | var stdin_writer = child.stdin.?.writerStreaming(io, &write_buffer); |
| 2206 | 2206 | _ = stdin_writer.interface.sendFileAll(&file_reader, .unlimited) catch |err| switch (err) { |
| 2207 | 2207 | error.ReadFailed => return run.step.fail("failed to read from {f}: {t}", .{ |
| 2208 | 2208 | path, file_reader.err.?, |