'Called when the stream should advance but the updates would be discarded,
e.g. when there are no currently connected workers.'

def discard_updates_and_advance(self):

    self.upto_token = self.current_token()
    self.last_token = self.upto_token
