Struct Buffers 

struct Buffers<'a> {
    out: &'a mut Vec<Buffer>,
}

Accumulates complete framed IPC messages as ordered buffers.

Fields

out: &'a mut Vec<Buffer>

Trait Implementations

impl IpcMessageSink for Buffers<'_>

fn write_slice(&mut self, bytes: &[u8]) -> Result<(), ArrowError>

fn write_vec(&mut self, bytes: Vec<u8>) -> Result<(), ArrowError>

fn write_encoded_buffer( &mut self, buffer: EncodedBuffer, ) -> Result<(), ArrowError>

impl IpcRecordBatchSink for Buffers<'_>

fn write_record_batch( &mut self, metadata: &[u8], encoded_buffers: &mut Vec<EncodedBuffer>, body_len: usize, write_options: &IpcWriteOptions, ) -> Result<(usize, usize), ArrowError>

Writes a record batch (or dictionary batch) message from its encoded metadata and body buffers.