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

 手机用户2502880437 发布于 2022-10-30 13:11

我的需求是这样的:

  • 第一个请求是login,拿到token

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

subscription = APIHelper.getAPIS().login(mUsername, mPwd)
                .flatMap(new Func1>() {
                    @Override
                    public Observable call(LoginSuccess loginSuccess) {
                        //存一下token 略
                        return APIHelper.getAPIS().getUserInfo(loginSuccess.getId());
                    }
                })
                .map(new Func1() {
                    @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() {
                
                    //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)的错误处理怎么办?

2 个回答
  • 在onError中处理就可以了。

    2022-11-12 01:39 回答
    1. 代码正常执行完会进入onCompleted,出错了会进入onError

    2. 可以在 maptry-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();
    });

    2022-11-12 01:39 回答
撰写答案
今天,你开发时遇到什么问题呢?
立即提问
热门标签
PHP1.CN | 中国最专业的PHP中文社区 | PNG素材下载 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有