retrofit - 如何在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"))

3，我尝试过以下。(重试)

// 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"))

这比一号要好。但没有记载。

我要使刷新按钮在出现错误后起作用。

我想知道

我可以保留或重新订阅订户吗？

这是Rxjava中的正确方法吗？

对不起，我的英语不好。

Answer 1

您的Nr。 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，它是“内部” Observable的一部分。