bb8 Update

Cargo.toml

@@ -14,7 +14,7 @@ cockroach = []
 default = [ "cockroach" ]
 
 [dependencies]
-bb8 = "0.8"
+bb8 = "0.9"
 async-trait = "0.1.81"
 diesel = { version = "2.2.2", default-features = false, features = [ "r2d2" ] }
 futures = "0.3"

examples/customize_connection.rs

@@ -1,21 +1,27 @@
 //! An example showing how to cutomize connections while using pooling.
 
+use std::future::Future;
+use std::pin::Pin;
+
 use async_bb8_diesel::{AsyncSimpleConnection, Connection, ConnectionError};
-use async_trait::async_trait;
 use diesel::pg::PgConnection;
 
 #[derive(Debug)]
 struct ConnectionCustomizer {}
 
 type DieselPgConn = Connection<PgConnection>;
 
-#[async_trait]
 impl bb8::CustomizeConnection<DieselPgConn, ConnectionError> for ConnectionCustomizer {
-    async fn on_acquire(&self, connection: &mut DieselPgConn) -> Result<(), ConnectionError> {
-        connection
-            .batch_execute_async("please execute some raw sql for me")
-            .await
-            .map_err(ConnectionError::from)
+    fn on_acquire<'a>(
+        &'a self,
+        connection: &'a mut DieselPgConn,
+    ) -> Pin<Box<dyn Future<Output = Result<(), ConnectionError>> + Send + 'a>> {
+        Box::pin(async move {
+            let res = connection
+                .batch_execute_async("please execute some raw sql for me")
+                .await;
+            res.map_err(ConnectionError::from)
+        })
     }
 }
 

src/connection_manager.rs

@@ -1,7 +1,6 @@
 //! An async-safe connection pool for Diesel.
 
 use crate::{Connection, ConnectionError};
-use async_trait::async_trait;
 use diesel::r2d2::{self, ManageConnection, R2D2Connection};
 use std::sync::{Arc, Mutex};
 
@@ -59,7 +58,6 @@ impl<T: Send + 'static> ConnectionManager<T> {
     }
 }
 
-#[async_trait]
 impl<T> bb8::ManageConnection for ConnectionManager<T>
 where
     T: R2D2Connection + Send + 'static,