#NEWLINE# def register_watcher( self , event_type , callback , register_timeout = None ) : #NEWLINE# #INDENT# self . _push_watchers [ event_type ] . add ( callback ) #NEWLINE# self . wait_for_response ( RegisterMessage ( event_list = [ event_type ] ) , timeout = self )