android - 在rxjava中map内进行错误处理应该怎么写？

问题描述

我的需求是这样的：

第一个请求是login，拿到token

第二个请求是用token作为参数去拿到用户信息 目前的写法是这样的：

subscription = APIHelper.getAPIS().login(mUsername, mPwd).flatMap(new Func1<LoginSuccess, Observable<User>>() { @Override public Observable<User> call(LoginSuccess loginSuccess) {//存一下token 略return APIHelper.getAPIS().getUserInfo(loginSuccess.getId()); }}).map(new Func1<User, User.UserBean>() { @Override public User.UserBean call(User user) {return user.getUser(); }}).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).doOnSubscribe(new Action0() { @Override public void call() {showLoading(R.string.login_message); }}).subscribe(new Subscriber<User.UserBean>() { //onError，onCompleted，略 @Override public void onNext(User.UserBean userBean) { //存一下用户信息，提示登录成功 略startActivity(new Intent(LoginActivity.this, MainActivity.class));finish(); }});

目前的问题：在login和userinfo两个接口的地方没有做错误处理。 在一些文章中看到可以在map里面做错误处理，但是我现在的写法只有后一个（userinfo）可以处理。 问题：

map中判断失败，进行处理以后后面的subscribe方法还会执行么？里面的onError，onCompleted回调会执行么？

如果使用了flapmap，第一个接口（login）的错误处理怎么办？

问题解答

代码正常执行完会进入onCompleted，出错了会进入onError；

可以在 map 里 try-catch处理错误；也可以在 onError 做统一处理。

.filter(userBean -> { // 请求失败 if (userBean.getCode() == 999) {Toast.makeText(MyActivity.this, userBean.getMsg(), Toast.LENGTH_SHORT).show();return false; } return true;}).subscribe(userBean -> { // 请求成功 startActivity(new Intent(LoginActivity.this, MainActivity.class)); finish();}, throwable -> { // 程序异常 Log.e('TAG', 'Error:' + throwable.getMessage()); // Toast.makeText(context, '登录失败', Toast.LENGTH_SHORT).show();});

回答2：

在onError中处理就可以了。