(&mut self, n: usize)
| 253 | } |
| 254 | |
| 255 | fn fill_buf(&mut self, n: usize) -> Result<(), AvroError> { |
| 256 | // We don't have enough space in the buffer, need to grow it. |
| 257 | if n >= self.buf.len() { |
| 258 | self.buf.resize(n, 0); |
| 259 | } |
| 260 | |
| 261 | self.inner.read_exact(&mut self.buf[..n])?; |
| 262 | self.buf_idx = 0; |
| 263 | Ok(()) |
| 264 | } |
| 265 | |
| 266 | fn read_block_next(&mut self) -> Result<(), AvroError> { |
| 267 | assert!(self.is_empty(), "Expected self to be empty!"); |
no test coverage detected