Struct ArrowStreamDeframer 

pub struct ArrowStreamDeframer { /* private fields */ }

Reassembles Arrow IPC stream chunks into complete ArrowFrames.

Frame format (simplified)

4 bytes   continuation marker  (must be 0xFF_FF_FF_FF)
4 bytes   metadata length LE u32  (0 → EOS)
N bytes   metadata flatbuffer
8 bytes   body length LE u64      (only when metadata_length > 0)
M bytes   body

Implementations

impl ArrowStreamDeframer

pub fn new() -> Self

Create a new deframer with default limits (64 MiB metadata, 2 GiB body).

pub fn with_limits(max_metadata_bytes: u32, max_body_bytes: u64) -> Self

Create a deframer with explicit limits.

pub fn is_idle(&self) -> bool

Returns true when the deframer is idle (waiting for the next frame’s continuation marker), i.e., no partial frame is buffered.

pub fn reset(&mut self)

Reset the deframer to the idle state. Increments the reset counter.

pub fn stats(&self) -> Arc<DeframerStats>

Return a clone of the shared statistics handle.

pub fn push(&mut self, data: &[u8]) -> Result<Vec<ArrowFrame>, DeframerError>

Feed data into the deframer. Returns all complete frames assembled during this call, or a DeframerError if the stream is malformed.

On error the deframer is automatically reset so the caller may attempt to continue with later data (e.g., after re-synchronisation).

Trait Implementations

impl Debug for ArrowStreamDeframer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ArrowStreamDeframer

fn default() -> Self

Returns the “default value” for a type.