'Called when there may be more deltas to process'

@defer.inlineCallbacks
def notify_new_event(self):

    if (not self.update_user_directory):
        return
    if self._is_processing:
        return
    self._is_processing = True
    try:
        (yield self._unsafe_process())
    finally:
        self._is_processing = False
