android - 使用 rxandroid 调用改造 api 时刷新身份验证 token

Question

我有工作改造 api，它返回可观察到的一些数据。

API 使用授权 token 访问服务器。当 auth token 过期时，我有关于它的错误消息(Observer 在订阅者中调用 onError)。

public Observable<MyObject> getObjectObservable() {
    return mApi.getObject();
}

我也可以用 observable 刷新 token :

private Observable<AuthResult> restoreToken() {
    return mApi.restoreToken(new RestoreTokenBody(getRestoreToken()));
}

如何在 getObjectObservable 函数中实现后续步骤:

• 首先尝试 mApi.getObject()
• 错误刷新 token
• 刷新后再次调用mApi.getObject()

Answer 1

尝试使用运算符 onErrorResumeNext 像这样:

public Observable<MyObject> getObjectObservable() {
    return mApi.getObject()
            .onErrorResumeNext(restoreToken().flatMap(authResult ->  mApi.getObject()));
}