Struct QueryStream 

pub struct QueryStream<T> { /* private fields */ }

Query builder for streaming results

This is a lightweight wrapper that helps construct streaming queries. It doesn’t implement Stream itself to avoid lifetime issues.

Implementations

impl<T> QueryStream<T>

where T: Send + 'static,

pub fn new(pool: &PgPool, query: impl Into<String>) -> Self

Create a new query stream builder

The pool is cloned (cheap operation as PgPool uses Arc internally)

pub async fn collect_vec(self) -> Result<Vec<T>>

where T: for<'r> FromRow<'r, PgRow> + Unpin,

Execute the query and collect all results into a Vec

This is the recommended method for most use cases.

pub async fn for_each<F, Fut>(self, processor: F) -> Result<u64>

where T: for<'r> FromRow<'r, PgRow> + Unpin, F: FnMut(T) -> Fut, Fut: Future<Output = Result<()>>,

Execute the query and process results one by one with a processor function

This is useful for processing large result sets without loading everything into memory.