#NEWLINE# def test_sequence_equal_not_equal_2( 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_next ( 490 , 8 ) , on_next ( 520 , 9 ) , on_next ( 580 , 10 ) , on_next ( 600 , 11 ) ] #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 , 9 ) , on_next ( 400 , 9 ) , on_next ( 410 , 10 ) , on_next ( 490 , 11 ) , on_next ( 550 , 12 ) , on_next ( 560 , 13 ) ] #NEWLINE# xs = scheduler . create_hot_observable ( msgs1 ) #NEWLINE# ys = scheduler . create_hot_observable ( xs ) #NEWLINE# results = scheduler . start ( create = ( lambda : xs . sequence_equal ( ys ) ) ) #NEWLINE# results . messages . assert_equal ( on_next ( 490 , False ) , on_completed ( 490 ) ) #NEWLINE# xs . subscriptions . assert_equal ( subscribe ( 200 , 490 ) ) #NEWLINE# ys . subscriptions . assert_equal ( subscribe ( 200 , 490 ) )