'Throw away any existing events so we don\'t replay history.'

def _run(self):

    self._client.get_events()
    while True:
        events = self._client.get_events()
        if events:
            self._process_events(events)
