Struct PreparedQueryStream 

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

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

Holding a PreparedQueryStream keeps the underlying connection 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> PreparedQueryStream<'a>

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

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

pub 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 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 PreparedQueryStream<'_>

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

Formats the value using the given formatter.

impl Drop for PreparedQueryStream<'_>

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.