#NEWLINE# def test_sequence_equal_not_equal_3( 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_completed ( 330 ) ] #NEWLINE# msgs2 = [ on_next ( 90 , 1 ) , on_next ( 270 , 3 ) , on_next ( 400 , 4 ) , on_completed ( 420 ) ] #NEWLINE# xs = scheduler . create_hot_observable ( msgs1 ) #NEWLINE# ys = scheduler . create_hot_observable ( msgs2 ) #NEWLINE# results = scheduler . start ( create = ( lambda : xs . sequence_equal ( ys ) ) ) #NEWLINE# results . messages . assert_equal ( on_next ( 420 , False ) , on_completed ( 420 ) ) #NEWLINE# xs . subscriptions . assert_equal ( subscribe ( 200 , 420 ) ) #NEWLINE# ys . subscriptions . assert_equal ( subscribe ( 200 , 420 ) )