#NEWLINE# def _flush_pipeline( self ) : #NEWLINE# #INDENT# self . io . flush_send ( ) #NEWLINE# while True : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# reply = self . reply_queue . pop ( 0 ) #NEWLINE# #UNINDENT# except IndexError : #NEWLINE# #INDENT# return None #NEWLINE# #UNINDENT# reply . recv ( self . io ) #NEWLINE# if reply . is_error ( ) : #NEWLINE# #INDENT# self . last_error = self