#NEWLINE# def _handle_read( self ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# pos = self . _read_to_buffer_loop ( ) #NEWLINE# #UNINDENT# except UnsatisfiableReadError : #NEWLINE# #INDENT# raise #NEWLINE# #UNINDENT# except Exception : #NEWLINE# #INDENT# gen_log . warning ( 'error on read' , exc_info = True ) #NEWLINE# self . close ( exc_info = True ) #NEWLINE# return #NEWLINE# #UNINDENT# if ( self is not None ) : #NEWLINE# #INDENT# self . _read_from_buffer ( pos ) #NEWLINE# return #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . _maybe_run_close_callback ( )