#NEWLINE# def test_max_int32_return( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# msgs = [ on_next ( 150 , 1 ) , on_next ( 210 , 2 ) , on_completed ( 250 ) ] #NEWLINE# xs = scheduler . create_hot_observable ( msgs ) #NEWLINE# def create( ) : #NEWLINE# #INDENT# return xs . max ( ) #NEWLINE# #UNINDENT# res = scheduler . start ( create = create ) . messages #NEWLINE# res . assert_equal ( on_next ( 250 , 2 ) , on_completed ( 250 ) )