(&self, buf: &'a [u8])
| 1078 | } |
| 1079 | |
| 1080 | fn read_message<'a>(&self, buf: &'a [u8]) -> Result<Message::Message<'a>, ArrowError> { |
| 1081 | let message = parse_message(buf)?; |
| 1082 | |
| 1083 | // some old test data's footer metadata is not set, so we account for that |
| 1084 | if self.version != MetadataVersion::V1 && message.version() != self.version { |
| 1085 | return Err(ArrowError::IpcError( |
| 1086 | "Could not read IPC message as metadata versions mismatch".to_string(), |
| 1087 | )); |
| 1088 | } |
| 1089 | Ok(message) |
| 1090 | } |
| 1091 | |
| 1092 | /// Read the dictionary with the given block and data buffer |
| 1093 | pub fn read_dictionary(&mut self, block: &Block, buf: &Buffer) -> Result<(), ArrowError> { |
no test coverage detected