#NEWLINE# def __init__( self , source , pauser = None ) : #NEWLINE# #INDENT# self . source = source #NEWLINE# self . controller = Subject ( ) #NEWLINE# if ( source and hasattr ( pauser , 'subscribe' ) ) : #NEWLINE# #INDENT# self . pauser = self . controller . merge ( pauser ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . pauser = self . controller #NEWLINE# #UNINDENT# super ( PausableBufferedObservable , self ) . __init__ ( self . _subscribe )