onError（RxJava）后如何保留订阅服务器

Question

第一，我试过了

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

第二，我尝试了下面的。（使用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"))

这比第一好。但没有刻录。

我想使刷新按钮，工作后错误。

我想知道

null

对不起，我的英语太差了。

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现在就会在每个错误之后调用，并且是“内部”可观察的一部分。