#NEWLINE# def test_return_observer_throws( self ) : #NEWLINE# #INDENT# scheduler1 = TestScheduler ( ) #NEWLINE# xs = Observable . return_value ( 1 , scheduler1 ) #NEWLINE# xs . subscribe ( ( lambda x : _raise ( 'ex' ) ) ) #NEWLINE# self . assertRaises ( RxException , scheduler1 . start ) #NEWLINE# scheduler2 = TestScheduler ( ) #NEWLINE# ys = Observable . return_value ( 1 , scheduler2 ) #NEWLINE# ys . subscribe ( ( lambda x : x ) , ( lambda ex : ex ) , ( lambda : _raise ( 'ex' ) ) ) #NEWLINE# self . assertRaises ( RxException , scheduler2 . start )