Struct GrpcChunkStreamSync 

pub struct GrpcChunkStreamSync { /* private fields */ }

Blocking wrapper around GrpcChunkStream.

Returned by GrpcClientSync::execute_query_stream and the AuthenticatedGrpcClientSync equivalent. Yields Arrow IPC byte chunks one at a time, blocking on the shared Tokio runtime as needed.

Pair with hyperdb_api::ArrowRowset::from_stream to decode Arrow record batches incrementally with constant client memory.

Implementations

impl GrpcChunkStreamSync

pub fn next_chunk(&mut self) -> Result<Option<Bytes>>

Returns the next Arrow IPC byte chunk, or None when the stream is complete.

Errors

Same failure modes as GrpcChunkStream::next_chunk — transport errors and server-side query failures surface as Error.

pub fn schema(&self) -> Option<&QueryResultSchema>

Returns the schema reported by the server, if one has been received yet.

pub fn query_id(&self) -> Option<&str>

Returns the server-assigned query ID, if one has been received.

pub fn rows_affected(&self) -> Option<u64>

Returns the affected row count for DML queries, if reported.

Trait Implementations

impl Debug for GrpcChunkStreamSync

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

Formats the value using the given formatter.