File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed
glide-core/redis-rs/redis/tests Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -56,14 +56,14 @@ mod cluster_async {
56
56
) -> redis:: RedisResult < redis:: Value > {
57
57
use futures_time:: time:: Duration ;
58
58
let mut delay_ms = 100u64 ;
59
-
59
+
60
60
for attempt in 0 ..max_retries {
61
61
let result = redis:: cmd ( "PUBLISH" )
62
62
. arg ( channel)
63
63
. arg ( message)
64
64
. query_async ( connection)
65
65
. await ;
66
-
66
+
67
67
match result {
68
68
Ok ( redis:: Value :: Int ( count) ) if count == expected_count => {
69
69
return Ok ( redis:: Value :: Int ( count) ) ;
@@ -81,7 +81,7 @@ mod cluster_async {
81
81
Err ( e) => return Err ( e) ,
82
82
}
83
83
}
84
-
84
+
85
85
// This should not be reached due to the loop logic above
86
86
unreachable ! ( )
87
87
}
@@ -95,14 +95,14 @@ mod cluster_async {
95
95
) -> redis:: RedisResult < redis:: Value > {
96
96
use futures_time:: time:: Duration ;
97
97
let mut delay_ms = 100u64 ;
98
-
98
+
99
99
for attempt in 0 ..max_retries {
100
100
let result = redis:: cmd ( "SPUBLISH" )
101
101
. arg ( channel)
102
102
. arg ( message)
103
103
. query_async ( connection)
104
104
. await ;
105
-
105
+
106
106
match result {
107
107
Ok ( redis:: Value :: Int ( count) ) if count == expected_count => {
108
108
return Ok ( redis:: Value :: Int ( count) ) ;
@@ -120,7 +120,7 @@ mod cluster_async {
120
120
Err ( e) => return Err ( e) ,
121
121
}
122
122
}
123
-
123
+
124
124
// This should not be reached due to the loop logic above
125
125
unreachable ! ( )
126
126
}
You can’t perform that action at this time.
0 commit comments