#NEWLINE# def test_sequence_equal_not_equal_right_sym( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# msgs1 = [ on_next ( 110 , 1 ) , on_next ( 190 , 2 ) , on_next ( 240 , 3 ) , on_next ( 290 , 4 ) , on_next ( 310 , 5 ) , on_next ( 340 , 6 ) , on_next ( 450 , 7 ) , on_completed ( 510 ) ] #NEWLINE# msgs2 = [ on_next ( 90 , 1 ) , on_next ( 270 , 3 ) , on_next ( 280 , 4 ) , on_next ( 300 , 5 ) , on_next ( 330 , 6 ) , on_next ( 340 , 7 ) , on_next ( 350 , 8 ) ] #NEWLINE# xs = scheduler . create_hot_observable ( msgs1 ) #NEWLINE# ys = scheduler . create_hot_observable ( msgs1 ) #NEWLINE# results = scheduler . start ( ( lambda : ys . sequence_equal ( xs ) ) ) #NEWLINE# results . messages . assert_equal ( on_next ( 510 , False ) , on_completed ( 510 ) ) #NEWLINE# xs . subscriptions . assert_equal ( subscribe ( 200 , 510 ) ) #NEWLINE# ys . subscriptions . assert_equal ( subscribe ( 200 , 510 ) )