¿Cómo terminar un observable?

Tengo un Observable que quiero terminar si una cierta condición no se cumple (es decir, si la respuesta de un sitio web determinado no tiene éxito), para que pueda volver a consultar el sitio web, y llamar a los observables de nuevo. ¿Cómo hago para hacerlo?

Esto es lo que quiero hacer:

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

Puede utilizar el operador de repetición de Rx. Y no es necesario terminar un observable.

Definición de una excepción personalizada:

 public class FailedException extends RuntimeException{ // ... } private static final int RETRY_COUNT = 3; // max retry counts Observable.create(new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? super String> subscriber) { //Perform network actions here if (!response.isSuccessful()) { // if response is unsucceed, invoke onError method and it will be stop emit data and into retry method. subscriber.onError(new FailedException()); } } }) .retry((integer, throwable) -> { // Retry network actions when failed. // if return true, Observable will be retry to network actions emit data; // if return false, you can process in onError() method of Subscribe. return throwable instanceof FailedException && integer < RETRY_COUNT; })

Puede filtrar el resultado antes de suscribirse. No lo maneje cuando crea su observable.

Compruebe la función observable.filter