in src/util.rs [106:114]
fn ipc_to_batch_helper(bytes: &[u8]) -> Result<RecordBatch, ArrowError> {
let mut stream_reader = StreamReader::try_new_buffered(Cursor::new(bytes), None)?;
match stream_reader.next() {
Some(Ok(batch_res)) => Ok(batch_res),
Some(Err(e)) => Err(e),
None => Err(ArrowError::IpcError("Expected a valid batch".into())),
}
}