Struct AsyncPool 

pub struct AsyncPool { /* private fields */ }

An async facade over a Pool.

with is the primitive: it checks a connection out of the pool and runs a closure against it on a blocking thread, releasing the checkout when the closure returns. This is deliberately the only way to touch a pooled connection — holding a long-lived pooled-connection guard across .await points is the classic way to deadlock an async pool, since it pins a pool slot for the entire suspension.

Implementations

impl AsyncPool

pub fn new(pool: Pool) -> AsyncPool

Wraps an existing Pool for async use.

pub fn pool(&self) -> &Pool

Returns the underlying Pool.

pub async fn state(&self) -> PoolState

Returns the pool’s current idle/active connection counts.

pub async fn with<F, T>(&self, f: F) -> Result<T>

where F: FnOnce(&mut Connection) -> Result<T> + Send + 'static, T: Send + 'static,

Checks a connection out of the pool and runs f against it on a blocking thread. The checkout is released when f returns.

This is the correct place to run a transaction: a transaction must not span an .await point.

Errors

Returns an error if checkout times out, or if the closure returns one.

pub async fn execute_batch<S>(&self, sql: S) -> Result<()>

where S: Into<String> + Send,

Executes one or more SQL statements separated by semicolons on a pooled connection.

Errors

Returns an error if checkout times out or any statement fails to execute.

pub async fn execute<S>(&self, sql: S) -> Result<ResultSet>

where S: Into<String> + Send,

Prepares and executes a SQL statement on a pooled connection, materializing the result.

Errors

Returns an error if checkout times out or the statement fails.

pub async fn execute_with<S>( &self, sql: S, binds: Vec<DuckValue>, ) -> Result<ResultSet>

where S: Into<String> + Send,

Prepares and executes a parameterized SQL statement on a pooled connection, materializing the result.

Errors

Returns an error if checkout times out, or preparation, binding, or execution fails.

Trait Implementations

impl Clone for AsyncPool

fn clone(&self) -> AsyncPool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.