Struct QueryStream 

pub struct QueryStream<'a> { /* private fields */ }

Streaming iterator for query results without materializing all rows.

Holding a QueryStream keeps the underlying RawConnection locked via a MutexGuard. Dropping the stream before fully iterating triggers a server-side cancel (see Drop below) so the connection is returned to the pool cleanly.

Implementations

impl QueryStream<'_>

pub fn schema(&self) -> Option<&[Column]>

Returns the schema (column metadata) for the result set.

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

Retrieves the next chunk of rows (up to chunk_size).

Errors

• Returns Error (I/O) if reading from the underlying transport fails while awaiting the next protocol message.
• Returns Error (server) when the server sends an ErrorResponse during streaming (for example, a server-side execution failure encountered partway through the result set).

Trait Implementations

impl Debug for QueryStream<'_>

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

Formats the value using the given formatter.

impl Drop for QueryStream<'_>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.