Method call

src/sql.rs:302–312

Allocates a connection and calls `function` with the connection. If `query_only` is true, allocates read-only connection, otherwise allocates write connection. Returns the result of the function.

(&'a self, query_only: bool, function: F)

    ///
    /// Returns the result of the function.
    pub async fn call<'a, F, R>(&'a self, query_only: bool, function: F) -> Result<R>
    where
        F: 'a + FnOnce(&mut Connection) -> Result<R> + Send,
        R: Send + 'static,
    {
        let lock = self.pool.read().await;
        let pool = lock.as_ref().context("no SQL connection")?;
        let mut conn = pool.get(query_only).await?;
        let res = tokio::task::block_in_place(move || function(&mut conn))?;
        Ok(res)
    }

    /// Allocates a connection and calls given function, assuming it does write queries, with the
    /// connection.