Struct AsyncQueryStream 

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

Streaming iterator for query results without materializing all rows (async).

Holding an AsyncQueryStream keeps the underlying AsyncRawConnection locked via a MutexGuard. Dropping the stream before fully iterating triggers a server-side cancel (see Drop below) so the connection is returned to a usable state.

Implementations

impl<'a> AsyncQueryStream<'a>

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

Returns the schema (column metadata) for the result set, once the first RowDescription has been read.

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

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

Returns Ok(Some(rows)) for each chunk, Ok(None) after the final ReadyForQuery, and Err(_) if the server sent an ErrorResponse.

Errors

• Returns Error (I/O) / Error (closed) if the async transport fails while awaiting the next protocol message.
• Returns Error (server) when the server sends an ErrorResponse partway through the result stream.

Trait Implementations

impl Debug for AsyncQueryStream<'_>

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

Formats the value using the given formatter.

impl Drop for AsyncQueryStream<'_>

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.