#NEWLINE# def _message_writer( self ) : #NEWLINE# #INDENT# object_writer = ObjectWriter ( self . _stream . writer ) #NEWLINE# for ( msg , ( remote_task_id , args ) , kwargs ) in Tasklet . receive ( ) : #NEWLINE# #INDENT# object_writer . write_object ( ( remote_task_id , msg . __class__ , id ( msg ) , args , object_writer ) ) #NEWLINE# object_writer . flush ( )