Struct AsyncPreparedQueryStream 

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

Streaming iterator for prepared-statement results without materializing all rows (async).

Holding an AsyncPreparedQueryStream keeps the underlying connection locked via a MutexGuard. Dropping the stream before fully iterating triggers a best-effort server-side cancel and marks the connection desynchronized — same Drop semantics as AsyncQueryStream.

Implementations

impl<'a> AsyncPreparedQueryStream<'a>

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

Returns the result schema (column metadata). Always available — the columns were captured at prepare time.

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

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

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 AsyncPreparedQueryStream<'_>

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

Formats the value using the given formatter.

impl Drop for AsyncPreparedQueryStream<'_>

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.