Как сохранить подписчика после OnError (RxJava)

Question

1-й, я попытался

// used retrofit 
public interface ApiService { 
    @GET(/get_some_data) 
    Observable<SomeData> getSomeData(); 
} 



// clickStream created by onClick event 
// No.1 
clickStream 
    .flatMap(e -> apiService.getSomeData()) 
    .subscribe(
     success -> Log.d("tag", "success"), 
     error -> Log.d("tag", "error"), 
     () -> Log.d("tag", "complete")) 

это хорошо, если getSomeData() успех. Я могу получить некоторые данные каждый клик.

но если произошла ошибка, отписаться. (так щелчок не работает после ошибки)

---

второй, я попытался ниже. (С onErrorResumeNext), но отписался.

(не называли OnError, но называется OnComplete. Так отписался)

// No.2 
clickStream 
    .flatMap(e -> apiService.getSomeData()) 
    .onErrorResumeNext(throwable -> Observable.empty()) // add this line 
    .subscribe(
     success -> Log.d("tag", "success"), 
     error -> Log.d("tag", "error"), 
     () -> Log.d("tag", "complete")) 

---

третий, я попытался ниже. (С повторной попытки)

// No.3 
clickStream 
    .flatMap(e -> apiService.getSomeData()) 
    .retry(5)           // add this line 
    .subscribe(
     success -> Log.d("tag", "success"), 
     error -> Log.d("tag", "error"), 
     () -> Log.d("tag", "complete")) 

это лучше, чем нет 0,1. но без записи.

---

Я хочу сделать кнопку обновления, которая работает после ошибки.

Я хочу знать

1. Могу ли я сохранить или повторно подписаться абонента?
2. Правильно ли это в Rxjava?

извините за плохой английский.

Answer 1

Ваш номер телефона. 2 был совсем близко - попробуйте это:

clickStream 
.flatMap(e -> apiService.getSomeData() 
    .onErrorResumeNext(throwable -> Observable.empty())) // add this line 
.subscribe(
    success -> Log.d("tag", "success"), 
    error -> Log.d("tag", "error"), 
    () -> Log.d("tag", "complete")) 

Обратите внимание, что я только переехал одну закрывающую скобку, так что onErrorResumeNext теперь называется после каждый ошибок и является частью «внутреннего» Наблюдаемый.