#NEWLINE# def load( self , index , sync , first_call ) : #NEWLINE# #INDENT# if sync : #NEWLINE# #INDENT# ( total , current ) = self . _sync_counters [ index ] #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# ( total , current ) = self . _load_counters [ index ] #NEWLINE# #UNINDENT# if ( current <= total ) : #NEWLINE# #INDENT# self . _api . fetch_data_to_queue ( index , current , self . _raw_data_queues [ index ] ) #NEWLINE# if first_call : #NEWLINE# #INDENT# self . _scheduled_data_count [ index ] = 0 #NEWLINE# #UNINDENT# #UNINDENT# else : #NEWLINE# #INDENT# raise CoubletNoMoreDataToFetch