(
&self,
version: u8,
tx_offset: u64,
reader: &mut R,
)
| 1155 | } |
| 1156 | |
| 1157 | fn consume_record<'a, R: spacetimedb_sats::buffer::BufReader<'a>>( |
| 1158 | &self, |
| 1159 | version: u8, |
| 1160 | tx_offset: u64, |
| 1161 | reader: &mut R, |
| 1162 | ) -> Result<(), Self::Error> { |
| 1163 | let decoder = ArrayDecoder::<32>; |
| 1164 | decoder.consume_record(version, tx_offset, reader)?; |
| 1165 | self.count.set(self.count.get() + 1); |
| 1166 | let expected_tx_offset = self.next_tx_offset.get(); |
| 1167 | assert_eq!(expected_tx_offset, tx_offset); |
| 1168 | self.next_tx_offset.set(expected_tx_offset + 1); |
| 1169 | Ok(()) |
| 1170 | } |
| 1171 | |
| 1172 | fn skip_record<'a, R: spacetimedb_sats::buffer::BufReader<'a>>( |
| 1173 | &self, |
no test coverage detected