#NEWLINE# def _run( self ) : #NEWLINE# #INDENT# "Throw away any existing events so we don't replay history." #NEWLINE# self . _client . get_events ( ) #NEWLINE# while True : #NEWLINE# #INDENT# events = self . _client . get_events ( ) #NEWLINE# if events : #NEWLINE# #INDENT# self . _process_events ( events )