Eu tenho um Observable que desejo encerrar se uma determinada condição não for atendida (ou seja, se a resposta de um determinado site for malsucedida), para que eu possa consultar novamente o site e chamar o observável novamente. Como faço para fazer isso?

Aqui está o que eu quero fazer:

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
        }
    }

});