Struct GrpcChunkStream 

pub struct GrpcChunkStream { /* private fields */ }

Streaming producer of Arrow IPC byte chunks from a gRPC query.

Unlike GrpcClient::execute_query, which drains every result chunk into a single GrpcQueryResult before returning, this type yields one Bytes chunk at a time. The caller can decode each chunk (e.g. via arrow_ipc::reader::StreamDecoder) and drop it before fetching the next, so memory stays bounded by roughly one message (capped at the tonic max_decoding_message_size, default 64 MB) regardless of total result size.

Built by GrpcClient::execute_query_stream and the AuthenticatedGrpcClient variant.

Implementations

impl GrpcChunkStream

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

Returns the next Arrow IPC byte chunk from the stream, or None when the server has signalled that the stream is complete.

Errors

Propagates any error from the underlying executor’s next_result call — typically tonic::Status errors wrapped as Error (server-side query failure, auth expiry, or transport-level gRPC errors).

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

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

The schema is typically delivered as the first message on the stream, so it is usually available after the first next_chunk() call.

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 GrpcChunkStream

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

Formats the value using the given formatter.