关于java:Android进阶学习RxJava八RxJava与Retrofit之双卡交火Pro

39次阅读

共计 1813 个字符，预计需要花费 5 分钟才能阅读完成。

先补一下上文的有余
doOnNext 很多小伙伴不是很了解，解释一下

doOnNext 通常用于后果解决之前的操作
比方，在网络申请收到返回值的时候，先验证一下返回值是否正确
比方，在收到数据时做一下缓存
比方，在收到状态码时做下判断
比方...

交火 Pro 侧重于嵌套类网络申请操作
次要实现性能
- 先获取所有的名字 -> 而后依据每个名字来获取对应个人信息
  一. 疾速的写一下获取所有名字

API_Protocol1 API_protocol = retrofit_rx.create(API_Protocol1.class);
Subscription subscribe = API_protocol.getAllName()
        .subscribeOn(Schedulers.newThread())// 申请在新的线程中执行
        .observeOn(Schedulers.io())         // 申请实现后在 io 线程中执行
        .observeOn(AndroidSchedulers.mainThread())// 最初在主线程中执行
        .subscribe(new Action1<AllNameBean>() {
            @Override
            public void call(AllNameBean allNameBean) {LogUtils.e(allNameBean.getInfo());
            }
        });

二. 开始革新

先更正一处谬误
接口包装类须要改成上面的样子能力拜访到带名字的具体数据
因为我在后端接口中做了只容许 POST 办法读取参数，所以要用 Field 字段去提交数据

@FormUrlEncoded
@POST(Urls1.get_name_info)
Observable<NameInfoBean> getNamesInfo(@Field("name") String name);

革新核心思想

如果应用循环嵌套的话，整个代码会变得异样臃肿且不优雅
核心思想是应用 from 代替循环，而后用 flatMap 将每个名字变成另外一个网络申请
如果放弃最后的程序性则应用 concatMap，用法雷同
而后对立在上游进行接管

三. 开始正餐
请看代码中的正文

API_Protocol1 API_protocol = retrofit_rx.create(API_Protocol1.class);
Subscription subscribe = API_protocol.getAllName()
        .subscribeOn(Schedulers.newThread())// 申请在新的线程中执行
        .observeOn(Schedulers.io())         // 申请实现后在 io 线程中执行
        .subscribe(new Action1<AllNameBean>() {
            @Override
            public void call(AllNameBean allNameBean) {List<String> data = allNameBean.getData();
                // 这里进行数组发送
                Observable.from(data)
                        .subscribeOn(Schedulers.newThread()) // 申请在新的线程中执行
                        .observeOn(Schedulers.newThread())
                        .flatMap(new Func1<String, Observable<NameInfoBean>>() {
                            @Override
                            public Observable<NameInfoBean> call(String s) {LogUtils.e(s);
                                // 发送通过网络申请的个人信息数据
                                return API_protocol.getNamesInfo(s);
                            }
                        })
                        .observeOn(AndroidSchedulers.mainThread())// 最初在主线程中执行
                        .subscribe(new Action1<NameInfoBean>() {
                            @Override
                            public void call(NameInfoBean nameInfoBean) {LogUtils.e(nameInfoBean.getData().get 姓名());
                                LogUtils.e(nameInfoBean.getData().get 喜好());
                            }
                        });
            }
        });