#NEWLINE# def send( self , msg ) : #NEWLINE# #INDENT# client_coroutine = self . loop . create_unix_connection ( _ClientProtocol , path = self . fname ) #NEWLINE# try : #NEWLINE# #INDENT# ( _ , client_proto ) = self . loop . run_until_complete ( self ) #NEWLINE# #UNINDENT# except OSError : #NEWLINE# #INDENT# raise IPCError ( ( 'Could not open %s' % self . fname ) ) #NEWLINE# #UNINDENT# client_proto . send ( msg , is_json = self . is_json ) #NEWLINE# try : #NEWLINE# #INDENT# self . loop . run_until_complete ( asyncio . wait_for ( client_proto . reply , timeout = 10 ) ) #NEWLINE# #UNINDENT# except asyncio . TimeoutError : #NEWLINE# #INDENT# raise RuntimeError ( 'Server not responding' ) #NEWLINE# #UNINDENT# return client_proto . reply . result ( )