У меня есть Observable, который я хочу прекратить, если не выполнено определенное условие (то есть, если ответ от определенного веб-сайта неуспешен), чтобы я мог повторно запросить веб-сайт и снова вызвать Observable. Как мне это сделать?

Вот что я хочу сделать:

Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {

        //Perform network actions here

        if (!response.isSuccessful()) {
            //terminate this Observable so I can retrieve the token and call this observable again
        }
    }

});