@@ -715,21 +715,22 @@ def test_with_method
715715
716716 def test_dedicated_multiple_keys_command
717717 [
718- { command : %w[ MSET key1 val1 ] , want : 'OK' } ,
718+ { command : %w[ MSET key1 val1 ] , want : 'OK' , wait : true } ,
719719 { command : %w[ MGET key1 ] , want : %w[ val1 ] } ,
720- { command : %w[ DEL key1 ] , want : 1 } ,
721- { command : %w[ MSET {key}1 val1 {key}2 val2 ] , want : 'OK' } ,
720+ { command : %w[ DEL key1 ] , want : 1 , wait : true } ,
721+ { command : %w[ MSET {key}1 val1 {key}2 val2 ] , want : 'OK' , wait : true } ,
722722 { command : %w[ MGET {key}1 {key}2 ] , want : %w[ val1 val2 ] } ,
723- { command : %w[ DEL {key}1 {key}2 ] , want : 2 } ,
724- { command : %w[ MSET key1 val1 key2 val2 ] , want : 'OK' } ,
723+ { command : %w[ DEL {key}1 {key}2 ] , want : 2 , wait : true } ,
724+ { command : %w[ MSET key1 val1 key2 val2 ] , want : 'OK' , wait : true } ,
725725 { command : %w[ MGET key1 key2 ] , want : %w[ val1 val2 ] } ,
726- { command : %w[ DEL key1 key2 ] , want : 2 } ,
727- { command : %w[ MSET key1 val1 key2 val2 ] , block : -> ( r ) { "#{ r } !" } , want : 'OK!' } ,
726+ { command : %w[ DEL key1 key2 ] , want : 2 , wait : true } ,
727+ { command : %w[ MSET key1 val1 key2 val2 ] , block : -> ( r ) { "#{ r } !" } , want : 'OK!' , wait : true } ,
728728 { command : %w[ MGET key1 key2 ] , block : -> ( r ) { r . map { |e | "#{ e } !" } } , want : %w[ val1! val2! ] } ,
729- { command : %w[ DEL key1 key2 ] , block : -> ( r ) { r == 2 } , want : true }
729+ { command : %w[ DEL key1 key2 ] , block : -> ( r ) { r == 2 } , want : true , wait : true }
730730 ] . each_with_index do |c , i |
731731 block = c . key? ( :block ) ? c . fetch ( :block ) : nil
732732 assert_equal ( c . fetch ( :want ) , @client . call_v ( c . fetch ( :command ) , &block ) , i + 1 )
733+ wait_for_replication if c . fetch ( :wait , false )
733734 end
734735 end
735736
0 commit comments