#NEWLINE# @ gen . coroutine #NEWLINE# def _read_body_until_close( self , delegate ) : #NEWLINE# #INDENT# body = ( yield self . stream . read_until_close ( ) ) #NEWLINE# if ( ( not delegate . _write_finished ) or self . is_client ) : #NEWLINE# #INDENT# with _ExceptionLoggingContext ( app_log ) : #NEWLINE# #INDENT# delegate . data_received ( body )