Struct ResultStream 

pub struct ResultStream<'session> { /* private fields */ }

Lazy, chunk-based result stream bound to a session’s lifetime.

Created by Session::execute_streaming. Iterate via next_chunk for chunk granularity or into_row_iter for a row iterator.

Stability: Experimental

Implementations

impl<'s> ResultStream<'s>

pub fn columns(&self) -> &[String]

Column names in the order they appear in each row.

pub fn column_types(&self) -> &[LogicalType]

Column types. Initially Any; refined after the first non-empty chunk.

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

Pulls the next chunk from the pipeline.

Returns Ok(None) when the stream is exhausted.

Errors

Propagates operator errors and returns Error::Query(QueryError::Timeout) if the session’s query deadline has passed.

pub fn into_row_iter(self) -> RowIterator<'s>

Converts to a row-level iterator that buffers one chunk internally.

pub fn collect(self) -> Result<QueryResult>

Drains the stream into a fully materialized QueryResult.

Useful as an escape hatch when a caller requested streaming but then decides to collect everything (e.g., stream.collect()? in tests).

Errors

Propagates operator errors and deadline timeouts.