Struct ArrowIpcReader 

pub struct ArrowIpcReader { /* private fields */ }

Cursor-based Arrow IPC message reader.

Implementations

impl ArrowIpcReader

pub fn new(data: Vec<u8>) -> Self

Creates a new reader wrapping data.

pub fn is_arrow_file(&self) -> bool

Returns true if data starts with the Arrow IPC magic bytes.

pub fn parse_file_header(&mut self) -> Result<(), StreamingError>

Validates and advances past the file header (magic + 2-byte padding).

Errors

Returns an error if the buffer does not start with the Arrow magic bytes.

pub fn next_message( &mut self, ) -> Result<Option<IpcMessageHeader>, StreamingError>

Reads and returns the next IPC message header, or Ok(None) at EOS.

Errors

Returns an error if the buffer is truncated mid-header.

pub fn read_buffer<'a>( &'a self, body_offset: u64, buf: &IpcBuffer, ) -> Option<&'a [u8]>

Returns the slice for an IpcBuffer relative to body_offset.

Returns None if the range falls outside the backing buffer.

pub fn data_len(&self) -> usize

Returns the total length of the backing buffer.

pub fn current_offset(&self) -> usize

Returns the current read cursor position.