<s> from rx . observable import Observable <EOL> from rx . internal import extensionclassmethod <EOL> @ extensionclassmethod ( Observable ) <EOL> def start_async ( cls , function_async ) : <EOL> """<STR_LIT>""" <EOL> try : <EOL> future = function_async ( ) <EOL> except Exception as ex : <EOL> return Observable . throw ( ex ) <EOL> return Observable . from_future ( future ) </s>
