#NEWLINE# def __init__( self , source , on_error ) : #NEWLINE# #INDENT# super ( JoinObserver , self ) . __init__ ( on_next = self . _next ) #NEWLINE# self . source = source #NEWLINE# self . on_error = on_error #NEWLINE# self . queue = [ ] #NEWLINE# self . active_plans = [ ] #NEWLINE# self . subscription = SingleAssignmentDisposable ( ) #NEWLINE# self . is_disposed = False