| ... | @@ -32,10 +32,10 @@ pub fn InStream(comptime ReadError: type) type { | ... | @@ -32,10 +32,10 @@ pub fn InStream(comptime ReadError: type) type { |
| 32 | /// End of stream is not an error condition. | 32 | /// End of stream is not an error condition. |
| 33 | pub fn read(self: *Self, buffer: []u8) Error!usize { | 33 | pub fn read(self: *Self, buffer: []u8) Error!usize { |
| 34 | if (std.io.is_async) { | 34 | if (std.io.is_async) { |
| | 35 | // Let's not be writing 0xaa in safe modes for upwards of 4 MiB for every stream read. |
| | 36 | @setRuntimeSafety(false); |
| 35 | var stack_frame: [stack_size]u8 align(stack_align) = undefined; | 37 | var stack_frame: [stack_size]u8 align(stack_align) = undefined; |
| 36 | // TODO https://github.com/ziglang/zig/issues/3068 | 38 | return await @asyncCall(&stack_frame, {}, self.readFn, self, buffer); |
| 37 | var result: Error!usize = undefined; | | |
| 38 | return await @asyncCall(&stack_frame, &result, self.readFn, self, buffer); | | |
| 39 | } else { | 39 | } else { |
| 40 | return self.readFn(self, buffer); | 40 | return self.readFn(self, buffer); |
| 41 | } | 41 | } |