#NEWLINE# def rci_1( a , b = 1 , coro = None ) : #NEWLINE# #INDENT# asyncoro . logger . debug ( 'running %s/%s with %s, %s' , coro . name , id ( coro ) , a , b ) #NEWLINE# msg = ( yield coro . receive ( ) ) #NEWLINE# if ( ( b % 2 ) == 0 ) : #NEWLINE# #INDENT# ( yield coro . sleep ( b ) ) #NEWLINE# asyncoro . logger . debug ( '%s/%s done' , coro . name , id ( coro ) ) #NEWLINE# raise StopIteration ( msg ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# raise Exception ( ( 'invalid invocation: %s' % b ) )