#NEWLINE# def test_distinct_until_changed_empty( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# xs = scheduler . create_hot_observable ( on_next ( 150 , 1 ) , on_completed ( 250 ) ) #NEWLINE# def create( ) : #NEWLINE# #INDENT# return xs . distinct_until_changed ( ) #NEWLINE# #UNINDENT# results = scheduler . start ( create ) . messages #NEWLINE# self . assertEqual ( 1 , len ( results ) ) #NEWLINE# assert ( ( results [ 0 ] . value . kind == 'C' ) and ( results [ 0 ] . time == 250 ) )