#NEWLINE# def test_slice_same( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# xs = scheduler . create_hot_observable ( on_next ( 70 , ( - 2 ) ) , on_next ( 150 , ( - 1 ) ) , on_next ( 210 , 0 ) , on_next ( 230 , 1 ) , on_next ( 270 , 2 ) , on_next ( 280 , 3 ) , on_next ( 300 , 4 ) , on_next ( 310 , 5 ) , on_next ( 340 , 6 ) , on_next ( 370 , 7 ) , on_next ( 410 , 8 ) , on_next ( 415 , 9 ) , on_completed ( 690 ) ) #NEWLINE# def create( ) : #NEWLINE# #INDENT# return xs [ 0 : 10 ] #NEWLINE# #UNINDENT# results = scheduler . start ( results ) #NEWLINE# results . messages . assert_equal ( on_next ( 210 , 0 ) , on_next ( 230 , 1 ) , on_next ( 270 , 2 ) , on_next ( 280 , 3 ) , on_next ( 300 , 4 ) , on_next ( 310 , 5 ) , on_next ( 340 , 6 ) , on_next ( 370 , 7 ) , on_next ( 410 , 8 ) , on_next ( 415 , 9 ) , on_completed ( 415 ) ) #NEWLINE# xs . subscriptions . assert_equal ( subscribe ( 200 , 415 ) )