#NEWLINE# def test_sequenceequal_enumerable_comparer_equal( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# xs = scheduler . create_hot_observable ( 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# def create( ) : #NEWLINE# #INDENT# def comparer( x , y ) : #NEWLINE# #INDENT# return ( ( x % 2 ) == ( y % 2 ) ) #NEWLINE# #UNINDENT# return xs . sequence_equal ( [ ( 3 - 2 ) , 4 , 5 , ( 6 + 42 ) , ( 7 - 6 ) ] , comparer ) #NEWLINE# #UNINDENT# res = scheduler . start ( create = res ) #NEWLINE# res . messages . assert_equal ( on_next ( 510 , True ) , on_completed ( 510 ) ) #NEWLINE# xs . subscriptions . assert_equal ( subscribe ( 200 , 510 ) )