(&mut self, snapshot: &Vec<(u64, u32)>)
| 232 | } |
| 233 | |
| 234 | pub fn restore_cursors(&mut self, snapshot: &Vec<(u64, u32)>) { |
| 235 | snapshot |
| 236 | .iter() |
| 237 | .for_each(|(key, cursor)| self.streams.get_mut(key).unwrap().cursor = *cursor); |
| 238 | } |
| 239 | } |
| 240 | |
| 241 | // pub fn multi_stream( |