#NEWLINE# def __init__( self ) : #NEWLINE# #INDENT# self . _api = CoubAPI ( raw_update_queues . PAGE ) #NEWLINE# self . _load_counters = load_counters = [ ] #NEWLINE# self . _sync_counters = sync_counters = [ ] #NEWLINE# self . _packets_queues = packets_queues = [ ] #NEWLINE# self . _raw_data_queues = raw_data_queues = [ ] #NEWLINE# self . _raw_update_queues = raw_update_queues = [ ] #NEWLINE# self . _scheduled_data_count = scheduled_data_count = [ ] #NEWLINE# self . _scheduled_update_count = scheduled_update_count = [ ] #NEWLINE# self . _packet_ids = packet_ids = [ ] #NEWLINE# for stream in CoubAPI . STREAM_NAMES : #NEWLINE# #INDENT# load_counters . append ( [ 1 , 1 ] ) #NEWLINE# sync_counters . append ( [ 1 , 1 ] ) #NEWLINE# raw_data_queues . append ( queue . Queue ( ) ) #NEWLINE# raw_update_queues . append ( queue . Queue ( ) ) #NEWLINE# packets_queues . append ( queue . Queue ( ) ) #NEWLINE# scheduled_data_count . append ( 0 ) #NEWLINE# scheduled_update_count . append ( 0 ) #NEWLINE# packet_ids . append ( set ( ) )