#NEWLINE# def test_find_never( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# xs = scheduler . create_hot_observable ( on_next ( 150 , 1 ) ) #NEWLINE# def create( ) : #NEWLINE# #INDENT# return xs . find ( ( lambda x , i , s : True ) ) #NEWLINE# #UNINDENT# res = scheduler . start ( create ) #NEWLINE# res . messages . assert_equal ( )