fix clippy

ayrat555 · Apr 15, 2024 · 201bc3b · 201bc3b
1 parent fe69c66
commit 201bc3b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 10 deletions.
diff --git a/fang/src/asynk/async_queue.rs b/fang/src/asynk/async_queue.rs
@@ -239,11 +239,11 @@ use std::env;
 
 use super::backend_sqlx::BackendSqlX;
 
-async fn get_backend(
+async fn get_pool(
     kind: AnyKind,
     _uri: &str,
     _max_connections: u32,
-) -> Result<(BackendSqlX, InternalPool), AsyncQueueError> {
+) -> Result<InternalPool, AsyncQueueError> {
     match kind {
         #[cfg(feature = "asynk-postgres")]
         AnyKind::Postgres => {
@@ -252,7 +252,7 @@ async fn get_backend(
                 .connect(_uri)
                 .await?;
 
-            Ok((BackendSqlX::Pg, InternalPool::Pg(pool)))
+            Ok(InternalPool::Pg(pool))
         }
         #[cfg(feature = "asynk-mysql")]
         AnyKind::MySql => {
@@ -261,7 +261,7 @@ async fn get_backend(
                 .connect(_uri)
                 .await?;
 
-            Ok((BackendSqlX::MySql, InternalPool::MySql(pool)))
+            Ok(InternalPool::MySql(pool))
         }
         #[cfg(feature = "asynk-sqlite")]
         AnyKind::Sqlite => {
@@ -270,7 +270,7 @@ async fn get_backend(
                 .connect(_uri)
                 .await?;
 
-            Ok((BackendSqlX::Sqlite, InternalPool::Sqlite(pool)))
+            Ok(InternalPool::Sqlite(pool))
         }
         #[allow(unreachable_patterns)]
         _ => panic!("Not a valid backend"),
@@ -293,7 +293,7 @@ impl AsyncQueue {
 
         let kind: AnyKind = self.uri.parse::<AnyConnectOptions>()?.kind();
 
-        let (backend, pool) = get_backend(kind, &self.uri, self.max_pool_size).await?;
+        let pool = get_pool(kind, &self.uri, self.max_pool_size).await?;
 
         self.pool = Some(pool);
         self.connected = true;

diff --git a/fang/src/asynk/backend_sqlx.rs b/fang/src/asynk/backend_sqlx.rs
@@ -92,7 +92,7 @@ impl BackendSqlX {
         _pool: &InternalPool,
         _params: QueryParams<'_>,
     ) -> Result<Res, AsyncQueueError> {
-        match self {
+        match *self {
             #[cfg(feature = "asynk-postgres")]
             BackendSqlX::Pg => {
                 BackendSqlXPg::execute_query(_query, _pool.unwrap_pg_pool(), _params).await
@@ -105,20 +105,18 @@ impl BackendSqlX {
             BackendSqlX::MySql => {
                 BackendSqlXMySQL::execute_query(_query, _pool.unwrap_mysql_pool(), _params).await
             }
-            _ => unreachable!(),
         }
     }
 
     // I think it is useful to have this method, although it is not used
     pub(crate) fn _name(&self) -> &str {
-        match self {
+        match *self {
             #[cfg(feature = "asynk-postgres")]
             BackendSqlX::Pg => BackendSqlXPg::_name(),
             #[cfg(feature = "asynk-sqlite")]
             BackendSqlX::Sqlite => BackendSqlXSQLite::_name(),
             #[cfg(feature = "asynk-mysql")]
             BackendSqlX::MySql => BackendSqlXMySQL::_name(),
-            _ => unreachable!(),
         }
     }
 }