转换可观察的 onError 并发出一个项目

Question

在我的Android应用程序中，我有一个生成的(Swagger(ApiClient，它使用令牌初始化以识别用户。

此令牌(来自服务器(可能会过期。

我通过myApiClient.myServiceMethod(params(从我的WebService获取带有数据的可观察数据

当我从服务器获得 401 时，这意味着我的令牌已过期，我必须再次初始化 myApiClient(才能使用未过期的令牌获取它(。

如何初始化 myApiClient。它由getMyApiClient((返回

//getOkHttpClientWithToken() first issues another Server call to get an
//unexpired Token and then returns an OkHttpClient with that Token set.
myApiClient = new ApiClient()
.getAdapterBuilder()
.baseUrl(url)
.client(getOkHttpClientWithToken())
.build()
.create(MyApiClient.class);

我从 myApiClient 调用中获取可观察量

Observable<Result> getResultObservable(Type param1, Type param2) {
return Observable.just(getMyApiClient())
.flatMap(myApiClient ->
myApiClient.getResult(param1, param2).cache()
);
}

我尝试的是

//How to recreate myApiClient and Retry call on new myApiClient when an Error occurs
getResultObservable(param1, param2)
.take(1)
.subscribe(result -> {
doSomethingWithResult();
}
});

有效，但在每个错误上都完成，而不仅仅是 401，可能永远不会结束

我需要类似的东西

getResultObservable(param1, param2)
.take(1)
.subscribe(result -> {
doSomethingWithResult();
}, e -> {
if(e.getMessage.equals("HTTP 401")) {
"Transform this Observable to getResultObservable with new myApiClient and emit Result in onNext"
} else {
"Other error inform User and stop."
}      
}
});

Answer 1

您可以使用Observable#onErrorResumeNext 来提供回退可观察。如果满足给定条件，您可以检查 typ 的异常并返回回退可观察，或者只是用 Observable#error 包装异常。

请查看测试，如何使用 #onErrorResumNext，以便在发生某些异常时提供可观察的回退。

@Test
void nameX() {
Observable<String> stringObservable = get();
Observable<String> fallback$ =
stringObservable
.doOnError(s -> System.out.println("fail -> " + s.getMessage()))
.onErrorResumeNext(
throwable -> {
if (throwable instanceof MyException) {
return fallBack().doOnNext(s -> System.out.println("use fallback value " + s));
} else {
return Observable.error(throwable);
}
});
fallback$
.test()
.assertNotComplete()
.assertValueCount(1)
.assertValueAt(0, s -> "Wurst".equals(s));
}
private Observable<String> get() {
return Observable.error(new MyException("Fail"));
}
private Observable<String> fallBack() {
return Observable.just("Wurst").mergeWith(Observable.never());
}
private static final class MyException extends Exception {
MyException(String message) {
super(message);
}
}