@@ -29,7 +29,7 @@ def test_inspect
29
29
def test_call
30
30
assert_raises ( ArgumentError ) { @client . call }
31
31
32
- ( 0 .. 9 ) . each do |i |
32
+ 10 . times do |i |
33
33
assert_equal ( 'OK' , @client . call ( 'SET' , "key#{ i } " , i ) , "Case: SET: key#{ i } " )
34
34
wait_for_replication
35
35
assert_equal ( i . to_s , @client . call ( 'GET' , "key#{ i } " ) , "Case: GET: key#{ i } " )
@@ -44,7 +44,7 @@ def test_call
44
44
def test_call_once
45
45
assert_raises ( ArgumentError ) { @client . call_once }
46
46
47
- ( 0 .. 9 ) . each do |i |
47
+ 10 . times do |i |
48
48
assert_equal ( 'OK' , @client . call_once ( 'SET' , "key#{ i } " , i ) , "Case: SET: key#{ i } " )
49
49
wait_for_replication
50
50
assert_equal ( i . to_s , @client . call_once ( 'GET' , "key#{ i } " ) , "Case: GET: key#{ i } " )
@@ -72,7 +72,7 @@ def test_blocking_call
72
72
def test_scan
73
73
assert_raises ( ArgumentError ) { @client . scan }
74
74
75
- ( 0 .. 9 ) . each { |i | @client . call ( 'SET' , "key#{ i } " , i ) }
75
+ 10 . times { |i | @client . call ( 'SET' , "key#{ i } " , i ) }
76
76
wait_for_replication
77
77
want = ( 0 ..9 ) . map { |i | "key#{ i } " }
78
78
got = [ ]
@@ -81,8 +81,8 @@ def test_scan
81
81
end
82
82
83
83
def test_sscan
84
- ( 0 .. 9 ) . each do |i |
85
- ( 0 .. 9 ) . each { |j | @client . call ( 'SADD' , "key#{ i } " , "member#{ j } " ) }
84
+ 10 . times do |i |
85
+ 10 . times { |j | @client . call ( 'SADD' , "key#{ i } " , "member#{ j } " ) }
86
86
wait_for_replication
87
87
want = ( 0 ..9 ) . map { |j | "member#{ j } " }
88
88
got = [ ]
@@ -92,8 +92,8 @@ def test_sscan
92
92
end
93
93
94
94
def test_hscan
95
- ( 0 .. 9 ) . each do |i |
96
- ( 0 .. 9 ) . each { |j | @client . call ( 'HSET' , "key#{ i } " , "field#{ j } " , j ) }
95
+ 10 . times do |i |
96
+ 10 . times { |j | @client . call ( 'HSET' , "key#{ i } " , "field#{ j } " , j ) }
97
97
wait_for_replication
98
98
want = ( 0 ..9 ) . map { |j | "field#{ j } " }
99
99
got = [ ]
@@ -103,8 +103,8 @@ def test_hscan
103
103
end
104
104
105
105
def test_zscan
106
- ( 0 .. 9 ) . each do |i |
107
- ( 0 .. 9 ) . each { |j | @client . call ( 'ZADD' , "key#{ i } " , j , "member#{ j } " ) }
106
+ 10 . times do |i |
107
+ 10 . times { |j | @client . call ( 'ZADD' , "key#{ i } " , j , "member#{ j } " ) }
108
108
wait_for_replication
109
109
want = ( 0 ..9 ) . map { |j | "member#{ j } " }
110
110
got = [ ]
@@ -118,18 +118,18 @@ def test_pipelined
118
118
119
119
want = ( 0 ..9 ) . map { 'OK' } + ( 1 ..3 ) . to_a + %w[ PONG ] + ( 0 ..9 ) . map ( &:to_s ) + [ %w[ list 2 ] ]
120
120
got = @client . pipelined do |pipeline |
121
- ( 0 .. 9 ) . each { |i | pipeline . call ( 'SET' , "string#{ i } " , i ) }
122
- ( 0 .. 2 ) . each { |i | pipeline . call ( 'RPUSH' , 'list' , i ) }
121
+ 10 . times { |i | pipeline . call ( 'SET' , "string#{ i } " , i ) }
122
+ 3 . times { |i | pipeline . call ( 'RPUSH' , 'list' , i ) }
123
123
pipeline . call_once ( 'PING' )
124
- ( 0 .. 9 ) . each { |i | pipeline . call ( 'GET' , "string#{ i } " ) }
124
+ 10 . times { |i | pipeline . call ( 'GET' , "string#{ i } " ) }
125
125
pipeline . blocking_call ( 0.2 , 'BRPOP' , 'list' , '0.1' )
126
126
end
127
127
128
128
assert_equal ( want , got )
129
129
end
130
130
131
131
def test_pubsub
132
- ( 0 .. 9 ) . each do |i |
132
+ 10 . times do |i |
133
133
pubsub = @client . pubsub
134
134
pubsub . call ( 'SUBSCRIBE' , "channel#{ i } " )
135
135
assert_equal ( [ 'subscribe' , "channel#{ i } " , 1 ] , pubsub . next_event ( 0.1 ) )
@@ -154,7 +154,7 @@ def test_close
154
154
end
155
155
156
156
def test_dedicated_commands
157
- ( 0 .. 9 ) . each { |i | @client . call ( 'SET' , "key#{ i } " , i ) }
157
+ 10 . times { |i | @client . call ( 'SET' , "key#{ i } " , i ) }
158
158
wait_for_replication
159
159
[
160
160
{ command : %w[ ACL HELP ] , is_a : Array } ,
0 commit comments