(&mut self)
| 224 | } |
| 225 | |
| 226 | pub fn trim(&mut self) { |
| 227 | self.streams.values_mut().for_each(|x| x.bytes.truncate(x.cursor as usize)); |
| 228 | } |
| 229 | |
| 230 | pub fn snapshot_cursors(&self) -> Vec<(u64, u32)> { |
| 231 | self.streams.iter().map(|(key, value)| (*key, value.cursor)).collect() |
no outgoing calls