#NEWLINE# @ gen . coroutine #NEWLINE# def _read_fixed_body( self , content_length , delegate ) : #NEWLINE# #INDENT# while ( content_length > 0 ) : #NEWLINE# #INDENT# body = ( yield self . stream . read_bytes ( min ( self . params . chunk_size , content_length ) , partial = True ) ) #NEWLINE# content_length -= len ( body ) #NEWLINE# if ( ( not self . _write_finished ) or self . is_client ) : #NEWLINE# #INDENT# with _ExceptionLoggingContext ( app_log ) : #NEWLINE# #INDENT# ( yield gen . maybe_future ( delegate . data_received ( body ) ) )