Enum IpcBodySink 

enum IpcBodySink<'a> {
    Write(&'a mut Vec<u8>),
    Collect(&'a mut Vec<EncodedBuffer>),
}

Destination for the raw Arrow data bytes (the IPC message body) produced by write_array_data.

The companion IpcMetadataBuilder accumulates the flatbuffer metadata (offset + length of each buffer in the body); together they form a complete IPC message.

Variants

Write(&'a mut Vec<u8>)

Serialize buffer bytes (with padding) into a contiguous byte vec.

Collect(&'a mut Vec<EncodedBuffer>)

Accumulate pre-encoded buffer segments for deferred zero-copy streaming.

Implementations

impl<'a> IpcBodySink<'a>

pub fn write(&mut self, pad_len: usize, buffer: EncodedBuffer)

Writes the encoded buffer to the sink.