| ... | ... | @@ -144,7 +144,7 @@ pub fn InStream(comptime ReadError: type) type { |
| 144 | 144 | /// If `buffer.len()` would exceed `max_size`, `error.StreamTooLong` is returned and the contents |
| 145 | 145 | /// read from the stream so far are lost. |
| 146 | 146 | pub fn readUntilDelimiterBuffer(self: &Self, buffer: &Buffer, delimiter: u8, max_size: usize) !void { |
| 147 | | try buf.resize(0); |
| 147 | try buffer.resize(0); |
| 148 | 148 | |
| 149 | 149 | while (true) { |
| 150 | 150 | var byte: u8 = try self.readByte(); |
| ... | ... | @@ -153,11 +153,11 @@ pub fn InStream(comptime ReadError: type) type { |
| 153 | 153 | return; |
| 154 | 154 | } |
| 155 | 155 | |
| 156 | | if (buf.len() == max_size) { |
| 156 | if (buffer.len() == max_size) { |
| 157 | 157 | return error.StreamTooLong; |
| 158 | 158 | } |
| 159 | 159 | |
| 160 | | try buf.appendByte(byte); |
| 160 | try buffer.appendByte(byte); |
| 161 | 161 | } |
| 162 | 162 | } |
| 163 | 163 | |
| ... | ... | @@ -171,7 +171,7 @@ pub fn InStream(comptime ReadError: type) type { |
| 171 | 171 | var buf = Buffer.initNull(allocator); |
| 172 | 172 | defer buf.deinit(); |
| 173 | 173 | |
| 174 | | try self.readUntilDelimiterBuffer(self, &buf, delimiter, max_size); |
| 174 | try self.readUntilDelimiterBuffer(&buf, delimiter, max_size); |
| 175 | 175 | return buf.toOwnedSlice(); |
| 176 | 176 | } |
| 177 | 177 | |