引言

  • 先补一下上文的有余
  • 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喜好());                            }                        });            }        });

总结

  • 的确比写循环好，优雅的多
  • 快些学起来呀
  • 一起加油哇

RxJava 与 Retrofit 系列的文章就到这里完结了，接下来要写更多 Android 世界里的常识
喜爱的小伙伴请随时关注，新文章不会晚