(&self, cursor_id: u64)
| 243 | } |
| 244 | |
| 245 | pub fn cursor_position(&self, cursor_id: u64) -> Result<u64, BufIoError> { |
| 246 | let cursors = self.cursors.read().map_err(|_| BufIoError::Locking)?; |
| 247 | cursors |
| 248 | .get(&cursor_id) |
| 249 | .map(|cursor| cursor.position) |
| 250 | .ok_or(BufIoError::InvalidCursor(cursor_id)) |
| 251 | } |
| 252 | |
| 253 | pub fn read_with_cursor(&self, cursor_id: u64, buf: &mut [u8]) -> Result<usize, BufIoError> { |
| 254 | let mut curr_pos = { |
no test coverage detected