Struct ArrowIpcStreamState 

pub struct ArrowIpcStreamState { /* private fields */ }

Wrapper type to internally manage the state and buffering of an Arrow IPC stream.

Helps bridge the async/sync gap between arrow’s sync primitives and async streaming.

Implementations

impl ArrowIpcStreamState

pub fn try_new( stream: SendableRecordBatchStream, chunk_size: Option<usize>, ) -> Result<Self>

Create a new ArrowIpcStreamState

Errors

• Returns an error if the StreamWriter cannot be created

pub fn take_chunk(&mut self, force: bool) -> Option<Bytes>

pub fn take_stream(self) -> SendableRecordBatchStream

pub fn into_parts(self) -> (SendableRecordBatchStream, StreamWriter<Vec<u8>>)

pub fn is_finished(&self) -> bool

pub fn is_emitted(&self) -> bool

pub async fn stream_chunks(self) -> Result<Option<(Bytes, Self)>>

Stream chunks from an Arrow IPC stream state.

Useful inside of stream::try_unfold to convert an Arrow IPC stream state into a stream of chunks.

Errors

• Returns an error if flushing fails