#NEWLINE# def handle( self , client_stream ) : #NEWLINE# #INDENT# remote_stream = RemoteStream ( client_stream ) #NEWLINE# while True : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# ( receiver_task_id , msg_class , msg_id , args , kwargs ) = remote_stream . read_msg ( ) #NEWLINE# #UNINDENT# except EOFError : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# msg = RemoteMessage ( remote_stream , msg_class , msg_id ) #NEWLINE# receiver_task = self . _task_by_task_id . get ( receiver_task_id , None ) #NEWLINE# if ( receiver_task is None ) : #NEWLINE# #INDENT# self . log . warn ( 'receiver task could not be found for remote msg delivery' ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# receiver_task . send ( msg , * args , ** kwargs )