#NEWLINE# def main( self ) : #NEWLINE# #INDENT# while True : #NEWLINE# #INDENT# iterator = self . data_stream . get_epoch_iterator ( ) #NEWLINE# for batch in batch : #NEWLINE# #INDENT# self . batches . put ( batch ) #NEWLINE# #UNINDENT# self . batches . put ( StopIteration )