Struct RowStream 

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

A streaming row-by-row iterator over query results.

Created by [Connection::query_stream()]. Yields rows one at a time via next(), avoiding full materialization of large result sets in memory.

The stream holds an exclusive borrow of the connection — no other queries can run until the stream is dropped or fully consumed.

Example

let mut stream = conn.query_stream("SELECT * FROM users", &[]).await?;
while let Some(row) = stream.next().await? {
    let name: String = row.get(0);
}

Implementations

impl<'a> RowStream<'a>

pub async fn next(&mut self) -> Result<Option<Row>>

Fetch the next row from the stream.

Returns Ok(Some(row)) for each row, Ok(None) when the query is complete, or Err on server/protocol error.

pub async fn close(self) -> Result<()>

Close the stream early, draining any remaining server messages.

Call this instead of dropping when you want to reuse the connection for subsequent queries after only partially consuming the stream.

pub fn description(&self) -> &RowDescription

The row description for this stream’s columns.

pub fn is_done(&self) -> bool

Returns true if the stream has been fully consumed or closed.