| ... | @@ -83,8 +83,6 @@ pub fn Decoder(comptime ReaderType: type) type { | ... | @@ -83,8 +83,6 @@ pub fn Decoder(comptime ReaderType: type) type { |
| 83 | } | 83 | } |
| 84 | | 84 | |
| 85 | fn readBlock(self: *Self) Error!void { | 85 | fn readBlock(self: *Self) Error!void { |
| 86 | const unpacked_pos = self.to_read.items.len; | | |
| 87 | | | |
| 88 | var block_counter = std.io.countingReader(self.inner_reader); | 86 | var block_counter = std.io.countingReader(self.inner_reader); |
| 89 | const block_reader = block_counter.reader(); | 87 | const block_reader = block_counter.reader(); |
| 90 | | 88 | |
| ... | @@ -165,7 +163,7 @@ pub fn Decoder(comptime ReaderType: type) type { | ... | @@ -165,7 +163,7 @@ pub fn Decoder(comptime ReaderType: type) type { |
| 165 | return error.CorruptInput; | 163 | return error.CorruptInput; |
| 166 | } | 164 | } |
| 167 | | 165 | |
| 168 | const unpacked_bytes = self.to_read.items[unpacked_pos..]; | 166 | const unpacked_bytes = self.to_read.items; |
| 169 | if (unpacked_size) |s| { | 167 | if (unpacked_size) |s| { |
| 170 | if (s != unpacked_bytes.len) | 168 | if (s != unpacked_bytes.len) |
| 171 | return error.CorruptInput; | 169 | return error.CorruptInput; |