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

Question

我的需求是这样的：

• 第一个请求是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）可以处理。
问题：

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

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

Answer 1

1. Selepas kod dijalankan seperti biasa, ia akan memasuki onCompleted, jika ralat berlaku, ia akan memasukkan onError

   ;
2. boleh mengendalikan ralat dalam

   peta cuba-tangkap; juga boleh mengendalikannya secara seragam dalam .
   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();
   });

Answer 2

Hanya mengendalikannya dalam onError.