#NEWLINE# def test_throw_observer_throws( self ) : #NEWLINE# #INDENT# scheduler = TestScheduler ( ) #NEWLINE# xs = Observable . throw_exception ( 'ex' , xs ) #NEWLINE# xs . subscribe ( ( lambda x : None ) , ( lambda ex : _raise ( 'ex' ) ) , ( lambda : None ) ) #NEWLINE# self . assertRaises ( RxException , scheduler . start )