#NEWLINE# def test_max_of_t_comparer_never( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# msgs = [ on_next ( 150 , 'z' ) ] #NEWLINE# def reverse_comparer( a , b ) : #NEWLINE# #INDENT# if ( a > b ) : #NEWLINE# #INDENT# return ( - 1 ) #NEWLINE# #UNINDENT# if ( a < b ) : #NEWLINE# #INDENT# return 1 #NEWLINE# #UNINDENT# return 0 #NEWLINE# #UNINDENT# xs = scheduler . create_hot_observable ( self ) #NEWLINE# def create( ) : #NEWLINE# #INDENT# return xs . max ( reverse_comparer ) #NEWLINE# #UNINDENT# res = scheduler . start ( create = create ) . messages #NEWLINE# res . assert_equal ( )