我是rxjava或rxandroid的新手,正在寻找处理多个请求的更好方法。我需要从服务器获取令牌,并将结果作为参数进行登录验证,如果返回成功,则通过getSessionId方法获取sessionId。我考虑过zip或merge,但我认为它不起作用。你能给我一个想法吗?或者我不知道,思路?非常感谢。
这是我的代码:
private void getToken(final String name , final String pwd){
api.newToken()
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<TokenModel>() {
@Override public void call(TokenModel tokenModel) {
String token = tokenModel.request_token;
if (!"".equals(token)){
login(token, name, pwd);
}else {
Timber.e("got token failed");
}
}
});
}
private void login(String token, String name, String pwd){
api.validateToken(token, name, pwd)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<TokenModel>() {
@Override public void call(TokenModel tokenModel) {
String token = tokenModel.request_token;
if (!"".equals(token)){
getSessionId(token);
}else {
Timber.e("got token failed");
}
}
});
}
private void getSessionId(String token){
api.newSessionn(token)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<TokenModel>() {
@Override public void onCompleted() {
//go to home activity
}
@Override public void onError(Throwable e) {
//handle error
}
@Override public void onNext(TokenModel tokenModel) {
//store session id
}
});
}
您的第一个订阅呼叫您的第二个订阅
您可以使用flapmap操作符来避免这种情况。
api.newToken(...)
.flapMap(token -> api.validateToken(token))
.flapMap(token -> api.newSession(token)).subscribe()
订阅中新的可观察对象通常可以被flatMap调用所取代。
如果你想管理你的错误,在flatMap中,如果令牌无效,你可以返回一个错误observable,而不是返回新的api调用observable。
.flatMap(token -> if(token.isValid){ return api.newCall(); } else { return Observable.error(...); ;)