#NEWLINE# def __init__( self , enable_queue = True ) : #NEWLINE# #INDENT# super ( ControlledSubject , self ) . __init__ ( self . _subscribe ) #NEWLINE# self . subject = Subject ( ) #NEWLINE# self . enable_queue = enable_queue #NEWLINE# self . queue = ( [ ] if enable_queue else None ) #NEWLINE# self . requested_count = 0 #NEWLINE# self . requested_disposable = Disposable . empty ( ) #NEWLINE# self . error = None #NEWLINE# self . has_failed = False #NEWLINE# self . has_completed = False #NEWLINE# self . controlled_disposable = Disposable . empty ( )