#NEWLINE# def test_skiplast_never( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# xs = scheduler . create_hot_observable ( ) #NEWLINE# def create( ) : #NEWLINE# #INDENT# return xs . skip_last_with_time ( 50 , scheduler ) #NEWLINE# #UNINDENT# res = scheduler . start ( self ) #NEWLINE# res . messages . assert_equal ( ) #NEWLINE# xs . subscriptions . assert_equal ( subscribe ( 200 , 1000 ) )