#NEWLINE# def client_send( conn , coro = None ) : #NEWLINE# #INDENT# thread_pool = asyncoro . AsyncThreadPool ( 1 ) #NEWLINE# if ( sys . version_info . major > 2 ) : #NEWLINE# #INDENT# read_input = input #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# read_input = raw_input #NEWLINE# #UNINDENT# while True : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# line = ( yield thread_pool . async_task ( read_input ) ) #NEWLINE# line = line . strip ( ) #NEWLINE# if ( line in ( 'quit' , 'exit' ) ) : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# #UNINDENT# except : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# ( yield conn . send_msg ( line . encode ( ) ) )