#NEWLINE# def __init__( self , pipeline ) : #NEWLINE# #INDENT# ' Creates the listener service. This also starts listening on the various\n        ports for updates ' #NEWLINE# RPObject . __init__ ( self ) #NEWLINE# self . _pipeline = pipeline #NEWLINE# self . _config_updates = set ( ) #NEWLINE# self . _daytime_updates = set ( ) #NEWLINE# self . _config_thread = self . listen_threaded ( self . CONFIG_PORT , self . _config_updates . add ) #NEWLINE# self . _daytime_thread = self . listen_threaded ( self . DAYTIME_PORT , self . _daytime_updates . add )