#NEWLINE# def _stop_producing( self ) : #NEWLINE# #INDENT# prod = prod . _producing #NEWLINE# del self . _producing #NEWLINE# for ( num , fut ) in prod : #NEWLINE# #INDENT# fut . throw ( PipeError ( ) ) #NEWLINE# #UNINDENT# self . _cond . notify ( )