#NEWLINE# def test_buffer_count_skip_more( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# xs = scheduler . create_hot_observable ( on_next ( 150 , 1 ) , on_next ( 210 , 2 ) , on_next ( 220 , 3 ) , on_next ( 230 , 4 ) , on_next ( 240 , 5 ) , on_completed ( 250 ) ) #NEWLINE# def create( ) : #NEWLINE# #INDENT# return xs . buffer_with_count ( 2 , 3 ) #NEWLINE# #UNINDENT# results = scheduler . start ( create ) . messages #NEWLINE# self . assertEqual ( 3 , len ( results ) ) #NEWLINE# assert ( sequence_equal ( xs [ 0 ] . value . value , [ 2 , 3 ] ) and ( results [ 0 ] . time == 220 ) ) #NEWLINE# assert ( sequence_equal ( results [ 1 ] . value . value , [ 5 ] ) and ( results [ 1 ] . time == 250 ) ) #NEWLINE# assert ( ( results [ 2 ] . value . kind == 'C' ) and ( results [ 2 ] . time == 250 ) )