#NEWLINE# def test_debounce_timespan_some_drop( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# xs = scheduler . create_hot_observable ( on_next ( 150 , 1 ) , on_next ( 250 , 2 ) , on_next ( 350 , 3 ) , on_next ( 370 , 4 ) , on_next ( 421 , 5 ) , on_next ( 480 , 6 ) , on_next ( 490 , 7 ) , on_next ( 500 , 8 ) , on_completed ( 600 ) ) #NEWLINE# def create( ) : #NEWLINE# #INDENT# return xs . debounce ( 50 , scheduler ) #NEWLINE# #UNINDENT# results = scheduler . start ( create ) #NEWLINE# return results . messages . assert_equal ( on_next ( 300 , 2 ) , on_next ( 420 , 4 ) , on_next ( 471 , 5 ) , on_next ( 550 , 8 ) , on_completed ( 600 ) )