#NEWLINE# def __init__( self , callbackScheduler , throughput ) : #NEWLINE# #INDENT# self . lock = threading . Lock ( ) #NEWLINE# self . listeners = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# self . rateLimitedChannelGroupsForEachListener = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# self . callbackScheduler = callbackScheduler #NEWLINE# self . perMachineThroughput = throughput