fix test

bikeshedder · Jul 29, 2024 · 53b1040 · 53b1040
1 parent 343aacb
commit 53b1040
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 17 deletions.
diff --git a/redis/README.md b/redis/README.md
@@ -30,7 +30,7 @@ async fn main() {
         let mut conn = pool.get().await.unwrap();
         cmd("SET")
             .arg(&["deadpool/test_key", "42"])
-            .query_async::<_, ()>(&mut conn)
+            .query_async::<()>(&mut conn)
             .await.unwrap();
     }
     {
@@ -74,7 +74,7 @@ async fn main() {
         let mut conn = pool.get().await.unwrap();
         cmd("SET")
             .arg(&["deadpool/test_key", "42"])
-            .query_async::<_, ()>(&mut conn)
+            .query_async::<()>(&mut conn)
             .await.unwrap();
     }
     {
@@ -108,7 +108,7 @@ async fn main() {
         let mut conn = pool.get().await.unwrap();
         cmd("SET")
             .arg(&["deadpool/test_key", "42"])
-            .query_async::<_, ()>(&mut conn)
+            .query_async::<()>(&mut conn)
             .await.unwrap();
     }
     {
@@ -158,7 +158,7 @@ async fn main() {
         let mut conn = pool.get().await.unwrap();
         cmd("SET")
             .arg(&["deadpool/test_key", "42"])
-            .query_async::<_, ()>(&mut conn)
+            .query_async::<()>(&mut conn)
             .await.unwrap();
     }
     {

diff --git a/redis/tests/redis.rs b/redis/tests/redis.rs
@@ -71,7 +71,7 @@ async fn test_aborted_command() {
         // https://github.com/mitsuhiko/redis-rs/issues/489
         cmd("PING")
             .arg("wrong")
-            .query_async::<_, String>(&mut conn)
+            .query_async::<String>(&mut conn)
             .now_or_never();
     }
     {
@@ -94,7 +94,7 @@ async fn test_recycled() {
 
         cmd("CLIENT")
             .arg("ID")
-            .query_async::<_, i64>(&mut conn)
+            .query_async::<i64>(&mut conn)
             .await
             .unwrap()
     };
@@ -104,7 +104,7 @@ async fn test_recycled() {
 
         let new_client_id = cmd("CLIENT")
             .arg("ID")
-            .query_async::<_, i64>(&mut conn)
+            .query_async::<i64>(&mut conn)
             .await
             .unwrap();
 
@@ -130,13 +130,13 @@ async fn test_recycled_with_watch() {
 
         let client_id = cmd("CLIENT")
             .arg("ID")
-            .query_async::<_, i64>(&mut conn)
+            .query_async::<i64>(&mut conn)
             .await
             .unwrap();
 
         cmd("WATCH")
             .arg(WATCHED_KEY)
-            .query_async::<_, ()>(&mut conn)
+            .query_async::<()>(&mut conn)
             .await
             .unwrap();
 
@@ -148,7 +148,7 @@ async fn test_recycled_with_watch() {
 
         let new_client_id = cmd("CLIENT")
             .arg("ID")
-            .query_async::<_, i64>(&mut txn_conn)
+            .query_async::<i64>(&mut txn_conn)
             .await
             .unwrap();
 
@@ -161,7 +161,7 @@ async fn test_recycled_with_watch() {
         // Start transaction on another key
         cmd("WATCH")
             .arg(TXN_KEY)
-            .query_async::<_, ()>(&mut txn_conn)
+            .query_async::<()>(&mut txn_conn)
             .await
             .unwrap();
 
@@ -172,7 +172,7 @@ async fn test_recycled_with_watch() {
             cmd("SET")
                 .arg(WATCHED_KEY)
                 .arg("v")
-                .query_async::<_, ()>(&mut writer_conn)
+                .query_async::<()>(&mut writer_conn)
                 .await
                 .unwrap();
         }
@@ -181,12 +181,12 @@ async fn test_recycled_with_watch() {
         let txn_result = pipe()
             .atomic()
             .set(TXN_KEY, "foo")
-            .query_async::<_, Value>(&mut txn_conn)
+            .query_async::<Value>(&mut txn_conn)
             .await
             .unwrap();
         assert_eq!(
             txn_result,
-            Value::Bulk(vec![Value::Okay]),
+            Value::Okay,
             "redis transaction in recycled connection aborted",
         );
     }

diff --git a/redis/tests/redis_cluster.rs b/redis/tests/redis_cluster.rs
@@ -76,7 +76,7 @@ async fn test_aborted_command() {
         // https://github.com/mitsuhiko/redis-rs/issues/489
         cmd("PING")
             .arg("wrong")
-            .query_async::<_, String>(&mut conn)
+            .query_async::<String>(&mut conn)
             .now_or_never();
     }
     {
@@ -99,7 +99,7 @@ async fn test_recycled() {
 
         cmd("CLIENT")
             .arg("ID")
-            .query_async::<_, i64>(&mut conn)
+            .query_async::<i64>(&mut conn)
             .await
             .unwrap()
     };
@@ -109,7 +109,7 @@ async fn test_recycled() {
 
         let new_client_id = cmd("CLIENT")
             .arg("ID")
-            .query_async::<_, i64>(&mut conn)
+            .query_async::<i64>(&mut conn)
             .await
             .unwrap();