(&self, reader: &mut impl Read)
| 82 | config, |
| 83 | )?) |
| 84 | } |
| 85 | |
| 86 | fn read_header(&self, reader: &mut impl Read) -> AvroResult<()> { |
| 87 | let mut header = vec![0; self.expected_header.len()]; |
| 88 | reader |
| 89 | .read_exact(&mut header) |
| 90 | .map_err(Details::ReadHeader)?; |
| 91 | if self.expected_header == header { |
| 92 | Ok(()) |
| 93 | } else { |
| 94 | Err(Details::SingleObjectHeaderMismatch(self.expected_header.clone(), header).into()) |
| 95 | } |
| 96 | } |
| 97 | } |
no test coverage detected