'Returns the maximum stream id such that all stream ids less than or
equal to it have been successfully persisted.
Returns:
int'

def get_current_token(self):

    with self._lock:
        if self._unfinished_ids:
            return (self._unfinished_ids[0] - self._step)
        return self._current
